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 public Object send(Message message) throws MessageBusException {
041 return _synchronousMessageSender.send(_destinationName, message);
042 }
043
044 public Object send(Message message, long timeout)
045 throws MessageBusException {
046
047 return _synchronousMessageSender.send(
048 _destinationName, message, timeout);
049 }
050
051 public Object send(Object payload) throws MessageBusException {
052 Message message = new Message();
053
054 message.setPayload(payload);
055
056 return send(message);
057 }
058
059 public Object send(Object payload, long timeout)
060 throws MessageBusException {
061
062 Message message = new Message();
063
064 message.setPayload(payload);
065
066 return send(message, timeout);
067 }
068
069 public void setDestinationName(String destinationName) {
070 _destinationName = destinationName;
071 }
072
073 public void setSynchronousMessageSender(
074 SynchronousMessageSender synchronousMessageSender) {
075
076 _synchronousMessageSender = synchronousMessageSender;
077 }
078
079 private String _destinationName;
080 private SynchronousMessageSender _synchronousMessageSender;
081
082 }