org.apache.activemq.artemis.core.protocol.core.impl

Class CoreSessionCallback

java.lang.Object

org.apache.activemq.artemis.core.protocol.core.impl.CoreSessionCallback

All Implemented Interfaces:

SessionCallback

public final class CoreSessionCallback
extends Object
implements SessionCallback

Constructor Summary

Constructors

Constructor and Description
CoreSessionCallback(String name, ProtocolManager protocolManager, Channel channel, RemotingConnection connection)

Method Summary

Modifier and Type	Method and Description
void	closed()
void	disconnect(ServerConsumer consumerId, String queueName)
boolean	hasCredits(ServerConsumer consumer) This one gives a chance for Proton to have its own flow control.
boolean	isWritable(ReadyListener callback)
int	sendLargeMessage(ServerMessage message, ServerConsumer consumer, long bodySize, int deliveryCount)
int	sendLargeMessageContinuation(ServerConsumer consumer, byte[] body, boolean continues, boolean requiresResponse)
int	sendMessage(ServerMessage message, ServerConsumer consumer, int deliveryCount)
void	sendProducerCreditsFailMessage(int credits, SimpleString address)
void	sendProducerCreditsMessage(int credits, SimpleString address)

Methods inherited from class java.lang.Object

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

Constructor Detail

CoreSessionCallback

public CoreSessionCallback(String name,
                           ProtocolManager protocolManager,
                           Channel channel,
                           RemotingConnection connection)

Method Detail

isWritable

public boolean isWritable(ReadyListener callback)

Specified by:

isWritable in interface SessionCallback

sendLargeMessage

public int sendLargeMessage(ServerMessage message,
                            ServerConsumer consumer,
                            long bodySize,
                            int deliveryCount)

Specified by:

sendLargeMessage in interface SessionCallback

sendLargeMessageContinuation

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

Specified by:

sendLargeMessageContinuation in interface SessionCallback

sendMessage

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

Specified by:

sendMessage in interface SessionCallback

sendProducerCreditsMessage

public void sendProducerCreditsMessage(int credits,
                                       SimpleString address)

Specified by:

sendProducerCreditsMessage in interface SessionCallback

sendProducerCreditsFailMessage

public void sendProducerCreditsFailMessage(int credits,
                                           SimpleString address)

Specified by:

sendProducerCreditsFailMessage in interface SessionCallback

closed

public void closed()

Specified by:

closed in interface SessionCallback

disconnect

public void disconnect(ServerConsumer consumerId,
                       String queueName)

Specified by:

disconnect in interface SessionCallback

hasCredits

public boolean hasCredits(ServerConsumer consumer)

Description copied from interface: SessionCallback

This one gives a chance for Proton to have its own flow control.

Specified by:

hasCredits in interface SessionCallback