01: /*
02: * MessageService: The message service daemon
03: * Copyright (C) 2006 Rift IT Contracting
04: *
05: * This library is free software; you can redistribute it and/or
06: * modify it under the terms of the GNU Lesser General Public
07: * License as published by the Free Software Foundation; either
08: * version 2.1 of the License, or (at your option) any later version.
09: *
10: * This library is distributed in the hope that it will be useful,
11: * but WITHOUT ANY WARRANTY; without even the implied warranty of
12: * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13: * Lesser General Public License for more details.
14: *
15: * You should have received a copy of the GNU Lesser General Public
16: * License along with this library; if not, write to the Free Software
17: * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
18: *
19: * MessageProducerImpl.java
20: */
21:
22: // package path
23: package com.rift.coad.daemon.messageservice;
24:
25: // java imports
26: import java.rmi.Remote;
27: import java.rmi.RemoteException;
28:
29: /**
30: * This class implements the MessageProducer interface. It is responsible for
31: * creating new producers on demand so that message can be added to the
32: * message service for processing by daemons.
33: *
34: * @author Brett Chaldecott
35: */
36: public class MessageProducerImpl implements MessageProducer {
37:
38: /**
39: * Creates a new instance of MessageProducerImpl
40: */
41: public MessageProducerImpl() {
42: }
43:
44: /**
45: * This method is responsible for creating the message producer session
46: * object.
47: *
48: * @return The message producer object.
49: * @param from The from url for the messages.
50: * @exception RemoteException
51: * @exception MessageServiceException
52: */
53: public Producer createProducer(String from) throws RemoteException,
54: MessageServiceException {
55: return new ProducerImpl(from);
56: }
57: }
|