public class ForwardingBridge extends java.lang.Object implements Service
Constructor and Description |
---|
ForwardingBridge(Transport localBroker,
Transport remoteBroker) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getClientId() |
long |
getDequeueCounter() |
java.lang.String |
getDestinationFilter() |
long |
getEnqueueCounter() |
java.lang.String |
getLocalAddress() |
java.lang.String |
getLocalBrokerName() |
int |
getPrefetchSize() |
java.lang.String |
getRemoteAddress() |
java.lang.String |
getRemoteBrokerName() |
boolean |
isDispatchAsync() |
protected void |
serviceLocalCommand(Command command) |
void |
serviceLocalException(java.lang.Throwable error) |
protected void |
serviceRemoteCommand(Command command) |
void |
serviceRemoteException(java.lang.Throwable error) |
void |
setClientId(java.lang.String clientId) |
void |
setDestinationFilter(java.lang.String destinationFilter) |
void |
setDispatchAsync(boolean dispatchAsync) |
void |
setNetworkBridgeFailedListener(NetworkBridgeListener listener) |
void |
setPrefetchSize(int prefetchSize) |
void |
start() |
void |
stop() |
protected void |
triggerStartBridge() |
public ForwardingBridge(Transport localBroker, Transport remoteBroker)
public void start() throws java.lang.Exception
protected void triggerStartBridge() throws java.io.IOException
java.io.IOException
public void stop() throws java.lang.Exception
public void serviceRemoteException(java.lang.Throwable error)
protected void serviceRemoteCommand(Command command)
public void serviceLocalException(java.lang.Throwable error)
protected void serviceLocalCommand(Command command)
public java.lang.String getClientId()
public void setClientId(java.lang.String clientId)
public int getPrefetchSize()
public void setPrefetchSize(int prefetchSize)
public boolean isDispatchAsync()
public void setDispatchAsync(boolean dispatchAsync)
public java.lang.String getDestinationFilter()
public void setDestinationFilter(java.lang.String destinationFilter)
public void setNetworkBridgeFailedListener(NetworkBridgeListener listener)
public java.lang.String getRemoteAddress()
public java.lang.String getLocalAddress()
public java.lang.String getLocalBrokerName()
public java.lang.String getRemoteBrokerName()
public long getDequeueCounter()
public long getEnqueueCounter()
Copyright © 2005-2012. All Rights Reserved.