Package org.openiam.common.beans.mq

Interface RabbitMQSender

All Known Implementing Classes:

RabbitMQSenderImpl

public interface RabbitMQSender

Method Summary

Modifier and Type	Method	Description
<API extends OpenIAMAPI> void	broadcast(String vhost, String exchange, API apiName, BaseServiceRequest apiRequest, String routingKey)
<API extends OpenIAMAPI> void	publish(MqQueue queue, API apiName, BaseServiceRequest apiRequest)
<API extends OpenIAMAPI> void	schedule(MqQueue queue, API apiName, Long delayMillis, Integer priority, BaseServiceRequest apiRequest)
<API extends OpenIAMAPI> void	schedule(MqQueue queue, API apiName, Long delayMillis, BaseServiceRequest apiRequest)
<API extends OpenIAMAPI> void	send(MqQueue queue, API apiName, BaseServiceRequest apiRequest)
<ApiResponse extends Response,API extends OpenIAMAPI> ApiResponse	sendAndReceive(MqQueue queue, API apiName, BaseServiceRequest apiRequest, Class<ApiResponse> apiResponseClass)

Method Detail

sendAndReceive

<ApiResponse extends Response,API extends OpenIAMAPI> ApiResponse sendAndReceive(MqQueue queue,
                                                                                       API apiName,
                                                                                       BaseServiceRequest apiRequest,
                                                                                       Class<ApiResponse> apiResponseClass)

send

<API extends OpenIAMAPI> void send(MqQueue queue,
                                   API apiName,
                                   BaseServiceRequest apiRequest)

schedule

<API extends OpenIAMAPI> void schedule(MqQueue queue,
                                       API apiName,
                                       Long delayMillis,
                                       BaseServiceRequest apiRequest)

schedule

<API extends OpenIAMAPI> void schedule(MqQueue queue,
                                       API apiName,
                                       Long delayMillis,
                                       Integer priority,
                                       BaseServiceRequest apiRequest)

publish

<API extends OpenIAMAPI> void publish(MqQueue queue,
                                      API apiName,
                                      BaseServiceRequest apiRequest)

broadcast

<API extends OpenIAMAPI> void broadcast(String vhost,
                                        String exchange,
                                        API apiName,
                                        BaseServiceRequest apiRequest,
                                        String routingKey)