public class ForwardingBridge extends Object implements Service
Constructor and Description |
---|
ForwardingBridge(Transport localBroker,
Transport remoteBroker) |
Modifier and Type | Method and Description |
---|---|
String |
getClientId() |
long |
getDequeueCounter() |
String |
getDestinationFilter() |
long |
getEnqueueCounter() |
String |
getLocalAddress() |
String |
getLocalBrokerName() |
int |
getPrefetchSize() |
String |
getRemoteAddress() |
String |
getRemoteBrokerName() |
boolean |
isDispatchAsync() |
protected void |
serviceLocalCommand(Command command) |
void |
serviceLocalException(Throwable error) |
protected void |
serviceRemoteCommand(Command command) |
void |
serviceRemoteException(Throwable error) |
void |
setClientId(String clientId) |
void |
setDestinationFilter(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)
protected void triggerStartBridge() throws IOException
IOException
public void serviceRemoteException(Throwable error)
protected void serviceRemoteCommand(Command command)
public void serviceLocalException(Throwable error)
protected void serviceLocalCommand(Command command)
public String getClientId()
public void setClientId(String clientId)
public int getPrefetchSize()
public void setPrefetchSize(int prefetchSize)
public boolean isDispatchAsync()
public void setDispatchAsync(boolean dispatchAsync)
public String getDestinationFilter()
public void setDestinationFilter(String destinationFilter)
public void setNetworkBridgeFailedListener(NetworkBridgeListener listener)
public String getRemoteAddress()
public String getLocalAddress()
public String getLocalBrokerName()
public String getRemoteBrokerName()
public long getDequeueCounter()
public long getEnqueueCounter()
Copyright © 2005–2017. All rights reserved.