GatewaySender
and GatewayReceiver
instead@Deprecated public interface Gateway
Gateway
represents a local proxy for a remote
WAN (or distributed system).Modifier and Type | Interface and Description |
---|---|
static interface |
Gateway.Endpoint
Deprecated.
An
Endpoint represents a proxy to a remote host |
static class |
Gateway.OrderPolicy
Deprecated.
The order policy.
|
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_CONCURRENCY_LEVEL
Deprecated.
The default number of parallel threads dispatching events from one member.
|
static int |
DEFAULT_SOCKET_BUFFER_SIZE
Deprecated.
The default buffer size for socket buffers from a sending
Gateway to its receiving Gateway . |
static int |
DEFAULT_SOCKET_READ_TIMEOUT
Deprecated.
The default amount of time in milliseconds that a socket read between a
sending
Gateway and its receiving Gateway will
block. |
static int |
MINIMUM_SOCKET_READ_TIMEOUT
Deprecated.
The default minimum socket read timeout.
|
static String |
SOCKET_READ_TIMEOUT_PROPERTY
Deprecated.
The obsolete socket read timeout java system property.
|
static String |
STARTUP_POLICY_PRIMARY
Deprecated.
The 'primary' startup policy.
|
Modifier and Type | Method and Description |
---|---|
void |
addEndpoint(String id,
String host,
int port)
Deprecated.
Add an
Endpoint to this Gateway . |
void |
addListener(GatewayEventListener listener)
Deprecated.
Add a
GatewayEventListener to this Gateway . |
int |
getConcurrencyLevel()
Deprecated.
Returns the concurrency level (number of parallel threads) processing
GatewayEvent s |
boolean |
getEarlyAck()
Deprecated.
EarlyAck communication is unsafe and no longer supported
|
List |
getEndpoints()
Deprecated.
Returns the list of
Endpoint s |
String |
getGatewayHubId()
Deprecated.
Returns this
Gateway 's GatewayHub identifier. |
String |
getId()
Deprecated.
Returns this
Gateway 's identifier. |
List<GatewayEventListener> |
getListeners()
Deprecated.
Returns the list of
GatewayEventListener s |
Gateway.OrderPolicy |
getOrderPolicy()
Deprecated.
Returns the
OrderPolicy for this Gateway . |
GatewayQueueAttributes |
getQueueAttributes()
Deprecated.
Returns the
GatewayQueueAttributes s for this Gateway |
int |
getQueueSize()
Deprecated.
Returns the number of entries in this
Gateway 's queue. |
int |
getSocketBufferSize()
Deprecated.
Returns the configured buffer size of the socket connection between this
Gateway and its receiving Gateway . |
int |
getSocketReadTimeout()
Deprecated.
Optional operation.
|
boolean |
hasEndpoints()
Deprecated.
Returns whether this
Gateway has Endpoint s |
boolean |
hasListeners()
Deprecated.
Returns whether this
Gateway has GatewayEventListener s |
boolean |
isConnected()
Deprecated.
Returns whether or not this
Gateway is connected to its
remote Gateway . |
boolean |
isPaused()
Deprecated.
Returns whether or not this
Gateway is running. |
boolean |
isRunning()
Deprecated.
Returns whether or not this
Gateway is running |
void |
pause()
Deprecated.
Pauses this
Gateway . |
void |
resume()
Deprecated.
Resumes this paused
Gateway . |
void |
setEarlyAck(boolean earlyAck)
Deprecated.
EarlyAck communication is unsafe and no longer supported
|
void |
setOrderPolicy(Gateway.OrderPolicy orderPolicy)
Deprecated.
Sets the
OrderPolicy for this Gateway . |
void |
setQueueAttributes(GatewayQueueAttributes queueAttributes)
Deprecated.
Sets the
GatewayQueueAttributes s for this
Gateway . |
void |
setSocketBufferSize(int socketBufferSize)
Deprecated.
Sets the buffer size in bytes of the socket connection between this
Gateway and its receiving Gateway . |
void |
setSocketReadTimeout(int socketReadTimeout)
Deprecated.
Optional operation.
|
void |
start()
Deprecated.
Starts this
Gateway . |
void |
stop()
Deprecated.
Stops this
Gateway . |
static final int DEFAULT_SOCKET_BUFFER_SIZE
Gateway
to its receiving Gateway
.static final String SOCKET_READ_TIMEOUT_PROPERTY
static final int DEFAULT_SOCKET_READ_TIMEOUT
Gateway
and its receiving Gateway
will
block.static final int MINIMUM_SOCKET_READ_TIMEOUT
static final int DEFAULT_CONCURRENCY_LEVEL
static final String STARTUP_POLICY_PRIMARY
GatewayHub
. If it can become the primary
GatewayHub
, it will. If not, then it will log a warning
and become a secondary GatewayHub
.String getGatewayHubId()
Gateway
's GatewayHub
identifier.Gateway
's GatewayHub
identifier.String getId()
Gateway
's identifier.Gateway
's identifier.void addEndpoint(String id, String host, int port) throws GatewayException
Endpoint
to this Gateway
.id
- The id of the endpointhost
- The host of the endpointport
- The port that the endpoint is listening onGatewayException
- if this Gateway
already defines
an Endpoint
with this idList getEndpoints()
Endpoint
sEndpoint
sboolean hasEndpoints()
Gateway
has Endpoint
sGateway
has Endpoint
svoid addListener(GatewayEventListener listener) throws GatewayException
GatewayEventListener
to this Gateway
.listener
- The GatewayEventListener
to addGatewayException
- if this Gateway
already defines
any Endpoint
sList<GatewayEventListener> getListeners()
GatewayEventListener
sGatewayEventListener
sboolean hasListeners()
Gateway
has GatewayEventListener
sGateway
has GatewayEventListener
s@Deprecated void setEarlyAck(boolean earlyAck)
Gateway
's
queue.earlyAck
- Whether or not to enable early acknowledgement for
batches sent from this Gateway
to its corresponding
Gateway
.UnsupportedOperationException
- because of deprecation@Deprecated boolean getEarlyAck()
Gateway
's
queue.Gateway
to its corresponding Gateway
.void setSocketBufferSize(int socketBufferSize)
Gateway
and its receiving Gateway
. The
default is 32768 bytes.socketBufferSize
- The size in bytes of the socket bufferint getSocketBufferSize()
Gateway
and its receiving Gateway
. The default
is 32768 bytes.Gateway
and its receiving Gateway
void setSocketReadTimeout(int socketReadTimeout)
Gateway
and its receiving Gateway
will
block. The default is 10000 seconds.socketReadTimeout
- The amount of time to blockint getSocketReadTimeout()
Gateway
and its receiving Gateway
will
block. The default is 10000 seconds.Gateway
and its receiving Gateway
will
blockvoid setQueueAttributes(GatewayQueueAttributes queueAttributes)
GatewayQueueAttributes
s for this
Gateway
. Calling setQueueAttributes on a stopped
Gateway
will destroy the existing queue and create a new
empty queue.queueAttributes
- The GatewayQueueAttributes
to useGatewayQueueAttributes getQueueAttributes()
GatewayQueueAttributes
s for this Gateway
GatewayQueueAttributes
s for this Gateway
void start() throws IOException
Gateway
. Once the hub is running, its
configuration cannot be changed.IOException
- If an error occurs while starting the Gateway
boolean isRunning()
Gateway
is runningvoid stop()
Gateway
. Note that the
Gateway
can be reconfigured and restarted if
desired.boolean isConnected()
Gateway
is connected to its
remote Gateway
.int getQueueSize()
Gateway
's queue.Gateway
's queuevoid pause()
Gateway
.void resume()
Gateway
.boolean isPaused()
Gateway
is running.int getConcurrencyLevel()
GatewayEvent
sGatewayEvent
sDEFAULT_CONCURRENCY_LEVEL
void setOrderPolicy(Gateway.OrderPolicy orderPolicy)
OrderPolicy
for this Gateway
.orderPolicy
- the OrderPolicy
for this Gateway
Gateway.OrderPolicy getOrderPolicy()
OrderPolicy
for this Gateway
.OrderPolicy
for this Gateway
Copyright © 1997-2017 Pivotal Software, Inc. All rights reserved.