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
GatewayEvents |
boolean |
getEarlyAck()
Deprecated.
EarlyAck communication is unsafe and no longer supported
|
List |
getEndpoints()
Deprecated.
Returns the list of
Endpoints |
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
GatewayEventListeners |
Gateway.OrderPolicy |
getOrderPolicy()
Deprecated.
Returns the
OrderPolicy for this Gateway. |
GatewayQueueAttributes |
getQueueAttributes()
Deprecated.
Returns the
GatewayQueueAttributess 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 Endpoints |
boolean |
hasListeners()
Deprecated.
Returns whether this
Gateway has GatewayEventListeners |
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
GatewayQueueAttributess 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()
EndpointsEndpointsboolean hasEndpoints()
Gateway has EndpointsGateway has Endpointsvoid addListener(GatewayEventListener listener) throws GatewayException
GatewayEventListener to this Gateway.listener - The GatewayEventListener to addGatewayException - if this Gateway already defines
any EndpointsList<GatewayEventListener> getListeners()
GatewayEventListenersGatewayEventListenersboolean hasListeners()
Gateway has GatewayEventListenersGateway has GatewayEventListeners@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 Gatewayvoid 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)
GatewayQueueAttributess 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()
GatewayQueueAttributess for this GatewayGatewayQueueAttributess for this Gatewayvoid start()
throws IOException
Gateway. Once the hub is running, its
configuration cannot be changed.IOException - If an error occurs while starting the Gatewayboolean 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()
GatewayEventsGatewayEventsDEFAULT_CONCURRENCY_LEVELvoid setOrderPolicy(Gateway.OrderPolicy orderPolicy)
OrderPolicy for this Gateway.orderPolicy - the OrderPolicy for this GatewayGateway.OrderPolicy getOrderPolicy()
OrderPolicy for this Gateway.OrderPolicy for this GatewayCopyright © 1997-2017 Pivotal Software, Inc. All rights reserved.