Package edu.internet2.middleware.grouperMessagingRabbitmq

Class GrouperMessagingRabbitmqSystem

java.lang.Object

edu.internet2.middleware.grouperMessagingRabbitmq.GrouperMessagingRabbitmqSystem

All Implemented Interfaces:

GrouperMessagingSystem

public class GrouperMessagingRabbitmqSystem
extends Object
implements GrouperMessagingSystem

docs on client: https://www.rabbitmq.com/tutorials/tutorial-one-java.html

Constructor Summary

Constructors

Modifier	Constructor	Description
	GrouperMessagingRabbitmqSystem()
protected	GrouperMessagingRabbitmqSystem(RabbitMQConnectionFactory connectionFactory)

Method Summary

Modifier and Type	Method	Description
GrouperMessageAcknowledgeResult	acknowledge(GrouperMessageAcknowledgeParam grouperMessageAcknowledgeParam)	tell the messaging system that these messages are processed generally the message system will use the message id.
void	closeConnection(String messagingSystemName)
GrouperMessageReceiveResult	receive(GrouperMessageReceiveParam grouperMessageReceiveParam)	this will generally block until there are messages to process.
GrouperMessageSendResult	send(GrouperMessageSendParam grouperMessageSendParam)	send a message to a queue name.

Methods inherited from class java.lang.Object

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

Constructor Details

GrouperMessagingRabbitmqSystem

public GrouperMessagingRabbitmqSystem()

GrouperMessagingRabbitmqSystem

protected GrouperMessagingRabbitmqSystem(RabbitMQConnectionFactory connectionFactory)

Method Details

send

public GrouperMessageSendResult send(GrouperMessageSendParam grouperMessageSendParam)

Description copied from interface: GrouperMessagingSystem

send a message to a queue name. Note, the recipient could be a queue or a topic (generally always one or the other) based on the implementation of the messaging system. Messages must be delievered in the order that collection iterator designates. If there is a problem delivering the messages, the implementation should log, wait (back off) and retry until it is successful.

Specified by:

send in interface GrouperMessagingSystem

Parameters:

grouperMessageSendParam - has the queue or topic, and the message(s) and perhaps args

Returns:

result

See Also:

• GrouperMessagingSystem.send(edu.internet2.middleware.grouperClient.messaging.GrouperMessageSendParam)

acknowledge

public GrouperMessageAcknowledgeResult acknowledge(GrouperMessageAcknowledgeParam grouperMessageAcknowledgeParam)

Description copied from interface: GrouperMessagingSystem

tell the messaging system that these messages are processed generally the message system will use the message id. Note, the objects sent to this method must be the same that were received in the receiveMessages method. If there is a problem delivering the messages, the implementation should wait (back off) and retry until it is successful. Alternatively the message should be returned to queue, returned to end of queue, or sent to another queue

Specified by:

acknowledge in interface GrouperMessagingSystem

Returns:

result

See Also:

• GrouperMessagingSystem.acknowledge(edu.internet2.middleware.grouperClient.messaging.GrouperMessageAcknowledgeParam)

receive

public GrouperMessageReceiveResult receive(GrouperMessageReceiveParam grouperMessageReceiveParam)

Description copied from interface: GrouperMessagingSystem

this will generally block until there are messages to process. These messages are ordered in the order that they were sent.

Specified by:

receive in interface GrouperMessagingSystem

Parameters:

grouperMessageReceiveParam - grouper messaging receive param

Returns:

a message or multiple messages. It will block until there are messages available for this recipient to process

See Also:

• GrouperMessagingSystem.receive(edu.internet2.middleware.grouperClient.messaging.GrouperMessageReceiveParam)

closeConnection

public void closeConnection(String messagingSystemName)