com.caucho.amqp.client
Class AmqpClientConnectionImpl
java.lang.Object
com.caucho.amqp.client.AmqpClientConnectionImpl
- All Implemented Interfaces:
- AmqpConnection, AmqpLinkFactory
public class AmqpClientConnectionImpl
- extends java.lang.Object
- implements AmqpConnection, AmqpLinkFactory
AMQP client
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
AmqpClientConnectionImpl
public AmqpClientConnectionImpl()
AmqpClientConnectionImpl
public AmqpClientConnectionImpl(java.lang.String hostname,
int port)
setHostname
public void setHostname(java.lang.String hostname)
setPort
public void setPort(int port)
isDisconnected
public boolean isDisconnected()
connect
public void connect()
createSenderFactory
public com.caucho.amqp.client.AmqpClientSenderFactory createSenderFactory()
createSender
public com.caucho.amqp.client.AmqpClientSender<?> createSender(java.lang.String address)
createReceiverFactory
public com.caucho.amqp.client.AmqpClientReceiverFactory createReceiverFactory()
- Specified by:
createReceiverFactory
in interface AmqpConnection
createReceiver
public AmqpReceiver<?> createReceiver(java.lang.String address)
- Specified by:
createReceiver
in interface AmqpConnection
createReceiverLink
public AmqpReceiverLink createReceiverLink(java.lang.String name,
java.lang.String address,
java.util.Map<java.lang.String,java.lang.Object> nodeProperties)
- Specified by:
createReceiverLink
in interface AmqpLinkFactory
createSenderLink
public AmqpSenderLink createSenderLink(java.lang.String name,
java.lang.String address,
DistributionMode distMode,
SettleMode settleMode,
java.util.Map<java.lang.String,java.lang.Object> nodeProperties)
- Specified by:
createSenderLink
in interface AmqpLinkFactory
nextLinkId
public int nextLinkId()
- Returns:
onClose
public void onClose()
close
public void close()
disconnect
public void disconnect()
toString
public java.lang.String toString()
- Overrides:
toString
in class java.lang.Object