Package org.openiam.common.beans.mq

Class RabbitMQSenderImpl

java.lang.Object

org.openiam.common.beans.mq.RabbitMQSenderImpl

All Implemented Interfaces:

RabbitMQSender

@Component
public class RabbitMQSenderImpl
extends Object
implements RabbitMQSender

Created by alexander on 05/09/16.

Constructor Summary

Constructors

Constructor	Description
RabbitMQSenderImpl()

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)

Methods inherited from class java.lang.Object

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

Constructor Detail

RabbitMQSenderImpl

public RabbitMQSenderImpl()

Method Detail

sendAndReceive

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

Specified by:

sendAndReceive in interface RabbitMQSender

send

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

Specified by:

send in interface RabbitMQSender

schedule

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

Specified by:

schedule in interface RabbitMQSender

schedule

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

Specified by:

schedule in interface RabbitMQSender

publish

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

Specified by:

publish in interface RabbitMQSender

broadcast

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

Specified by:

broadcast in interface RabbitMQSender