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

Constructor Summary

Constructors

Constructor and Description
AmqpClientConnectionImpl()
AmqpClientConnectionImpl(java.lang.String hostname, int port)

Method Summary

Modifier and Type	Method and Description
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