org.apache.activemq.artemis.core.protocol.openwire.amq

Class AMQSession

java.lang.Object

org.apache.activemq.artemis.core.protocol.openwire.amq.AMQSession

All Implemented Interfaces:

SessionCallback

public class AMQSession
extends Object
implements SessionCallback

Field Summary

Fields

Modifier and Type	Field and Description
protected IDGenerator	consumerIDGenerator

Constructor Summary

Constructors

Constructor and Description
AMQSession(org.apache.activemq.command.ConnectionInfo connInfo, org.apache.activemq.command.SessionInfo sessInfo, ActiveMQServer server, OpenWireConnection connection, ScheduledExecutorService scheduledPool)

Method Summary

Modifier and Type	Method and Description
void	afterDelivery()
void	browserFinished(ServerConsumer consumer)
void	close()
void	closed()
List<AMQConsumer>	createConsumer(org.apache.activemq.command.ConsumerInfo info, SlowConsumerDetectionListener slowConsumerDetectionListener)
void	deliverMessage(org.apache.activemq.command.MessageDispatch dispatch)
void	disableSecurity()
void	disconnect(ServerConsumer consumerId, String queueName)
OpenWireConnection	getConnection()
org.apache.activemq.command.ConnectionInfo	getConnectionInfo()
OpenWireMessageConverter	getConverter()
ActiveMQServer	getCoreServer()
ServerSession	getCoreSession()
org.apache.activemq.wireformat.WireFormat	getMarshaller()
boolean	hasCredits(ServerConsumer consumer)
void	initialize()
boolean	isClosed()
boolean	isWritable(ReadyListener callback)
void	send(org.apache.activemq.command.ProducerInfo producerInfo, org.apache.activemq.command.Message messageSend, boolean sendProducerAck)
int	sendLargeMessage(MessageReference reference, ServerMessage message, ServerConsumer consumerID, long bodySize, int deliveryCount)
int	sendLargeMessageContinuation(ServerConsumer consumerID, byte[] body, boolean continues, boolean requiresResponse)
int	sendMessage(MessageReference reference, ServerMessage message, ServerConsumer consumer, int deliveryCount)
void	sendProducerCreditsFailMessage(int credits, org.apache.activemq.artemis.api.core.SimpleString address)
void	sendProducerCreditsMessage(int credits, org.apache.activemq.artemis.api.core.SimpleString address)
void	start()
boolean	updateDeliveryCountAfterCancel(ServerConsumer consumer, MessageReference ref, boolean failed)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

consumerIDGenerator

protected final IDGenerator consumerIDGenerator

Constructor Detail

AMQSession

public AMQSession(org.apache.activemq.command.ConnectionInfo connInfo,
                  org.apache.activemq.command.SessionInfo sessInfo,
                  ActiveMQServer server,
                  OpenWireConnection connection,
                  ScheduledExecutorService scheduledPool)

Method Detail

isClosed

public boolean isClosed()

getConverter

public OpenWireMessageConverter getConverter()

initialize

public void initialize()

updateDeliveryCountAfterCancel

public boolean updateDeliveryCountAfterCancel(ServerConsumer consumer,
                                              MessageReference ref,
                                              boolean failed)

Specified by:

updateDeliveryCountAfterCancel in interface SessionCallback

createConsumer

public List<AMQConsumer> createConsumer(org.apache.activemq.command.ConsumerInfo info,
                                        SlowConsumerDetectionListener slowConsumerDetectionListener)
                                 throws Exception

Throws:

Exception

start

public void start()

afterDelivery

public void afterDelivery()
                   throws Exception

Specified by:

afterDelivery in interface SessionCallback

Throws:

Exception

browserFinished

public void browserFinished(ServerConsumer consumer)

Specified by:

browserFinished in interface SessionCallback

isWritable

public boolean isWritable(ReadyListener callback)

Specified by:

isWritable in interface SessionCallback

sendProducerCreditsMessage

public void sendProducerCreditsMessage(int credits,
                                       org.apache.activemq.artemis.api.core.SimpleString address)

Specified by:

sendProducerCreditsMessage in interface SessionCallback

sendProducerCreditsFailMessage

public void sendProducerCreditsFailMessage(int credits,
                                           org.apache.activemq.artemis.api.core.SimpleString address)

Specified by:

sendProducerCreditsFailMessage in interface SessionCallback

sendMessage

public int sendMessage(MessageReference reference,
                       ServerMessage message,
                       ServerConsumer consumer,
                       int deliveryCount)

Specified by:

sendMessage in interface SessionCallback

sendLargeMessage

public int sendLargeMessage(MessageReference reference,
                            ServerMessage message,
                            ServerConsumer consumerID,
                            long bodySize,
                            int deliveryCount)

Specified by:

sendLargeMessage in interface SessionCallback

sendLargeMessageContinuation

public int sendLargeMessageContinuation(ServerConsumer consumerID,
                                        byte[] body,
                                        boolean continues,
                                        boolean requiresResponse)

Specified by:

sendLargeMessageContinuation in interface SessionCallback

closed

public void closed()

Specified by:

closed in interface SessionCallback

hasCredits

public boolean hasCredits(ServerConsumer consumer)

Specified by:

hasCredits in interface SessionCallback

disconnect

public void disconnect(ServerConsumer consumerId,
                       String queueName)

Specified by:

disconnect in interface SessionCallback

send

public void send(org.apache.activemq.command.ProducerInfo producerInfo,
                 org.apache.activemq.command.Message messageSend,
                 boolean sendProducerAck)
          throws Exception

Throws:

Exception

getCoreSession

public ServerSession getCoreSession()

getCoreServer

public ActiveMQServer getCoreServer()

getMarshaller

public org.apache.activemq.wireformat.WireFormat getMarshaller()

getConnectionInfo

public org.apache.activemq.command.ConnectionInfo getConnectionInfo()

disableSecurity

public void disableSecurity()

deliverMessage

public void deliverMessage(org.apache.activemq.command.MessageDispatch dispatch)

close

public void close()
           throws Exception

Throws:

Exception

getConnection

public OpenWireConnection getConnection()