Package org.apache.activemq.artemis.core.client.impl

Class ClientProducerImpl

java.lang.Object

org.apache.activemq.artemis.core.client.impl.ClientProducerImpl

All Implemented Interfaces:

AutoCloseable, ClientProducer, ClientProducerInternal

public class ClientProducerImpl
extends Object
implements ClientProducerInternal

Constructor Summary

Constructors

Constructor	Description
ClientProducerImpl(ClientSessionInternal session, SimpleString address, TokenBucketLimiter rateLimiter, boolean blockOnNonDurableSend, boolean blockOnDurableSend, boolean autoGroup, SimpleString groupID, int minLargeMessageSize, SessionContext sessionContext, int producerID)

Method Summary

Modifier and Type	Method	Description
void	cleanUp()
void	close()	Closes the ClientProducer.
SimpleString	getAddress()	Returns the address where messages will be sent; the address can be null if the ClientProducer was created without specifying an address, e.g. by using ClientSession.createProducer().
int	getID()
int	getMaxRate()	Returns the maximum rate at which a ClientProducer can send messages per second.
ClientProducerCredits	getProducerCredits()
boolean	isBlockOnDurableSend()	Returns true if the producer blocks when sending durable messages, false else.
boolean	isBlockOnNonDurableSend()	Returns true if the producer blocks when sending non-durable messages, false else.
boolean	isClosed()	Returns true if the producer is closed, false else.
void	send(String address1, Message message)	Sends a message to the specified address instead of the ClientProducer's address.
void	send(Message msg)	Sends a message to an address. specified in ClientSession.createProducer(String) or similar methods.
void	send(Message message, SendAcknowledgementHandler handler)	Sends a message to the specified address instead of the ClientProducer's address.
void	send(SimpleString address1, Message msg)	Sends a message to the specified address instead of the ClientProducer's address.
void	send(SimpleString address1, Message message, SendAcknowledgementHandler handler)	Sends a message to the specified address instead of the ClientProducer's address.

Methods inherited from class java.lang.Object

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

Constructor Details

ClientProducerImpl

public ClientProducerImpl(ClientSessionInternal session,
 SimpleString address,
 TokenBucketLimiter rateLimiter,
 boolean blockOnNonDurableSend,
 boolean blockOnDurableSend,
 boolean autoGroup,
 SimpleString groupID,
 int minLargeMessageSize,
 SessionContext sessionContext,
 int producerID)

Method Details

getAddress

public SimpleString getAddress()

Description copied from interface: ClientProducer

Returns the address where messages will be sent; the address can be null if the ClientProducer was created without specifying an address, e.g. by using ClientSession.createProducer().

Specified by:

getAddress in interface ClientProducer

Returns:

the address where messages will be sent; the address can be null if the ClientProducer was created without specifying an address, e.g. by using ClientSession.createProducer()

send

public void send(Message msg)
          throws ActiveMQException

Description copied from interface: ClientProducer

Sends a message to an address. specified in ClientSession.createProducer(String) or similar methods.

This will block until confirmation that the message has reached the server has been received if ServerLocator.setBlockOnDurableSend(boolean) or ServerLocator.setBlockOnNonDurableSend(boolean) are set to true for the specified message type.

Specified by:

send in interface ClientProducer

Parameters:

msg - the message to send

Throws:

ActiveMQException - if an exception occurs while sending the message

send

public void send(SimpleString address1,
 Message msg)
          throws ActiveMQException

Description copied from interface: ClientProducer

Sends a message to the specified address instead of the ClientProducer's address.

This will block until confirmation that the message has reached the server has been received if ServerLocator.setBlockOnDurableSend(boolean) or ServerLocator.setBlockOnNonDurableSend(boolean) are set to true for the specified message type.

Specified by:

send in interface ClientProducer

Parameters:

address1 - the address where the message will be sent

msg - the message to send

Throws:

ActiveMQException - if an exception occurs while sending the message

send

public void send(String address1,
 Message message)
          throws ActiveMQException

Description copied from interface: ClientProducer

Sends a message to the specified address instead of the ClientProducer's address.

This will block until confirmation that the message has reached the server has been received if ServerLocator.setBlockOnDurableSend(boolean) or ServerLocator.setBlockOnNonDurableSend(boolean) are set to true for the specified message type.

Specified by:

send in interface ClientProducer

Parameters:

address1 - the address where the message will be sent

message - the message to send

Throws:

ActiveMQException - if an exception occurs while sending the message

send

public void send(SimpleString address1,
 Message message,
 SendAcknowledgementHandler handler)
          throws ActiveMQException

Description copied from interface: ClientProducer

Sends a message to the specified address instead of the ClientProducer's address.

This message will be sent asynchronously as long as ServerLocator.setConfirmationWindowSize(int) was set.

Notice that if no confirmationWindowsize is set

Specified by:

send in interface ClientProducer

Parameters:

address1 - the address where the message will be sent

message - the message to send

handler - handler to call after receiving a SEND acknowledgement from the server

Throws:

ActiveMQException - if an exception occurs while sending the message

send

public void send(Message message,
 SendAcknowledgementHandler handler)
          throws ActiveMQException

Description copied from interface: ClientProducer

Sends a message to the specified address instead of the ClientProducer's address.

This message will be sent asynchronously.

The handler will only get called if -1.

Specified by:

send in interface ClientProducer

Parameters:

message - the message to send

handler - handler to call after receiving a SEND acknowledgement from the server

Throws:

ActiveMQException - if an exception occurs while sending the message

close

public void close()
           throws ActiveMQException

Description copied from interface: ClientProducer

Closes the ClientProducer. If already closed nothing is done.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface ClientProducer

Throws:

ActiveMQException - if an exception occurs while closing the producer

cleanUp

public void cleanUp()

Specified by:

cleanUp in interface ClientProducerInternal

isClosed

public boolean isClosed()

Description copied from interface: ClientProducer

Returns true if the producer is closed, false else.

Specified by:

isClosed in interface ClientProducer

Returns:

true if the producer is closed, false else

isBlockOnDurableSend

public boolean isBlockOnDurableSend()

Description copied from interface: ClientProducer

Returns true if the producer blocks when sending durable messages, false else.

Specified by:

isBlockOnDurableSend in interface ClientProducer

Returns:

true if the producer blocks when sending durable messages, false else

isBlockOnNonDurableSend

public boolean isBlockOnNonDurableSend()

Description copied from interface: ClientProducer

Returns true if the producer blocks when sending non-durable messages, false else.

Specified by:

isBlockOnNonDurableSend in interface ClientProducer

Returns:

true if the producer blocks when sending non-durable messages, false else

getMaxRate

public int getMaxRate()

Description copied from interface: ClientProducer

Returns the maximum rate at which a ClientProducer can send messages per second.

Specified by:

getMaxRate in interface ClientProducer

Returns:

the maximum rate at which a ClientProducer can send messages per second

getProducerCredits

public ClientProducerCredits getProducerCredits()

Specified by:

getProducerCredits in interface ClientProducerInternal

getID

public int getID()

Specified by:

getID in interface ClientProducerInternal