Package org.serviceconnector.service

Class PublishService

java.lang.Object

org.serviceconnector.service.Service

org.serviceconnector.service.StatefulService

org.serviceconnector.service.PublishService

All Implemented Interfaces:

IPublishService

Direct Known Subclasses:

CacheGuardian

public class PublishService
extends StatefulService
implements IPublishService

The Class PublishService. PublishService is a remote interface in client API to a publish service and provides communication functions.

Field Summary

Fields inherited from class org.serviceconnector.service.StatefulService

listOfServers, serverIndex

Constructor Summary

Constructors

Constructor	Description
PublishService(String name)	Instantiates a new publish service.

Method Summary

Modifier and Type	Method	Description
void	allocateServerAndSubscribe(SCMPMessage msgToForward, SubscribeCommandCallback callback, Subscription subscription, int timeoutMillis)	Allocate server and subscribe.
void	dump(XMLDumpWriter writer)	Dump the service into the xml writer.
PublishMessageQueue<SCMPMessage>	getMessageQueue()	Gets the subscription queue.

Methods inherited from class org.serviceconnector.service.StatefulService

addServer, getCountAllocatedSessions, getCountAvailableSessions, getCountServers, getServerList, notifyRemovedSession, removeServer, toString

Methods inherited from class org.serviceconnector.service.Service

getName, getType, isEnabled, setEnabled

Methods inherited from class java.lang.Object

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

Constructor Details

PublishService

public PublishService(String name)

Instantiates a new publish service.

Parameters:

name - the name

Method Details

getMessageQueue

public PublishMessageQueue<SCMPMessage> getMessageQueue()

Gets the subscription queue.

Specified by:

getMessageQueue in interface IPublishService

Returns:

the subscription queue

allocateServerAndSubscribe

public void allocateServerAndSubscribe(SCMPMessage msgToForward,
 SubscribeCommandCallback callback,
 Subscription subscription,
 int timeoutMillis)
                                throws Exception

Allocate server and subscribe.

Parameters:

msgToForward - the msg to forward

callback - the callback

subscription - the subscription

timeoutMillis - the timeout millis

Throws:

Exception - the exception

dump

public void dump(XMLDumpWriter writer)
          throws Exception

Description copied from class: StatefulService

Dump the service into the xml writer.

Overrides:

dump in class StatefulService

Parameters:

writer - the writer

Throws:

Exception - the exception