com.caucho.amqp.client
Class AmqpClientConnectionImpl

java.lang.Object
  extended by com.caucho.amqp.client.AmqpClientConnectionImpl
All Implemented Interfaces:
AmqpConnection, AmqpLinkFactory

public class AmqpClientConnectionImpl
extends java.lang.Object
implements AmqpConnection, AmqpLinkFactory

AMQP client


Constructor Summary
AmqpClientConnectionImpl()
           
AmqpClientConnectionImpl(java.lang.String hostname, int port)
           
 
Method Summary
 void close()
           
 void connect()
           
 AmqpReceiver<?> createReceiver(java.lang.String address)
           
 com.caucho.amqp.client.AmqpClientReceiverFactory createReceiverFactory()
           
 AmqpReceiverLink createReceiverLink(java.lang.String name, java.lang.String address, java.util.Map<java.lang.String,java.lang.Object> nodeProperties)
           
 com.caucho.amqp.client.AmqpClientSender<?> createSender(java.lang.String address)
           
 com.caucho.amqp.client.AmqpClientSenderFactory createSenderFactory()
           
 AmqpSenderLink createSenderLink(java.lang.String name, java.lang.String address, DistributionMode distMode, SettleMode settleMode, java.util.Map<java.lang.String,java.lang.Object> nodeProperties)
           
 void disconnect()
           
 boolean isDisconnected()
           
 int nextLinkId()
           
 void onClose()
           
 void setHostname(java.lang.String hostname)
           
 void setPort(int port)
           
 java.lang.String toString()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

AmqpClientConnectionImpl

public AmqpClientConnectionImpl()

AmqpClientConnectionImpl

public AmqpClientConnectionImpl(java.lang.String hostname,
                                int port)
Method Detail

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