001
014
015 package com.liferay.portal.kernel.messaging.sender;
016
017 import com.liferay.portal.kernel.messaging.Message;
018 import com.liferay.portal.kernel.messaging.MessageBusException;
019
020
023 public class DefaultSingleDestinationSynchronousMessageSender
024 implements SingleDestinationSynchronousMessageSender {
025
026 public DefaultSingleDestinationSynchronousMessageSender() {
027 }
028
029
032 public DefaultSingleDestinationSynchronousMessageSender(
033 String destinationName,
034 SynchronousMessageSender synchronousMessageSender) {
035
036 _destinationName = destinationName;
037 _synchronousMessageSender = synchronousMessageSender;
038 }
039
040 @Override
041 public Object send(Message message) throws MessageBusException {
042 return _synchronousMessageSender.send(_destinationName, message);
043 }
044
045 @Override
046 public Object send(Message message, long timeout)
047 throws MessageBusException {
048
049 return _synchronousMessageSender.send(
050 _destinationName, message, timeout);
051 }
052
053 @Override
054 public Object send(Object payload) throws MessageBusException {
055 Message message = new Message();
056
057 message.setPayload(payload);
058
059 return send(message);
060 }
061
062 @Override
063 public Object send(Object payload, long timeout)
064 throws MessageBusException {
065
066 Message message = new Message();
067
068 message.setPayload(payload);
069
070 return send(message, timeout);
071 }
072
073 public void setDestinationName(String destinationName) {
074 _destinationName = destinationName;
075 }
076
077 public void setSynchronousMessageSender(
078 SynchronousMessageSender synchronousMessageSender) {
079
080 _synchronousMessageSender = synchronousMessageSender;
081 }
082
083 private String _destinationName;
084 private SynchronousMessageSender _synchronousMessageSender;
085
086 }