eventweb.prov

Class PublishProvFtry.PublishProvImp

java.lang.Object

eventweb.prov.PublishProvFtry.PublishProvImp

All Implemented Interfaces:

SrvcProvImp

Enclosing class:

PublishProvFtry

public class PublishProvFtry.PublishProvImp
extends java.lang.Object
implements SrvcProvImp

Field Summary

Fields inherited from interface eventweb.prov.SrvcProvImp

IF_VERSION

Constructor Summary

Constructors

Constructor and Description
PublishProvFtry.PublishProvImp()

Method Summary

Methods

Modifier and Type	Method and Description
boolean	addSubscription(TvOutput subscriber, java.lang.String pubTopic)
int	dispatchRqst(TvList msgRec, TvOutput chnl, java.lang.String[] srvrCmd) Dispatch channel request.
protected void	dumpSubscriptions()
void	handleDisconnect(TvOutput client) Clean up after the client disconnects.
void	listSubscriptions(java.lang.String pubTopic, TvOutput toClient)
int	publish(TvList publication, TvOutput toPublisher) Publish a TvList.
int	publishEx(TvList publication, java.util.Set<TvOutput> excludeSet) Publish a TvList with multiple excludes.
boolean	removeSubscription(TvOutput subscriber, java.lang.String pubTopic)

Methods inherited from class java.lang.Object

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

Constructor Detail

PublishProvFtry.PublishProvImp

public PublishProvFtry.PublishProvImp()

Method Detail

dispatchRqst

public int dispatchRqst(TvList msgRec,
               TvOutput chnl,
               java.lang.String[] srvrCmd)

Dispatch channel request.

Specified by:

dispatchRqst in interface SrvcProvImp

Parameters:

msgRec - The client request message

chnl - Connection back to the client

srvrCmd - Allows a command to be passed back to the server.

Returns:

HTTP Status code

handleDisconnect

public void handleDisconnect(TvOutput client)

Description copied from interface: SrvcProvImp

Clean up after the client disconnects.

Specified by:

handleDisconnect in interface SrvcProvImp

Parameters:

client - The channel to the client that has disconnected

publish

public int publish(TvList publication,
          TvOutput toPublisher)

Publish a TvList.

Parameters:

publication - The TvList to publish

toPublisher - Destination to be excluded. (can be null)

Returns:

Number of messages sent

publishEx

public int publishEx(TvList publication,
            java.util.Set<TvOutput> excludeSet)

Publish a TvList with multiple excludes.

Parameters:

publication - The TvList to publish

excludeSet - Destinations to be excluded. (can be null)

Returns:

Number of messages sent

addSubscription

public boolean addSubscription(TvOutput subscriber,
                      java.lang.String pubTopic)

removeSubscription

public boolean removeSubscription(TvOutput subscriber,
                         java.lang.String pubTopic)

listSubscriptions

public void listSubscriptions(java.lang.String pubTopic,
                     TvOutput toClient)

dumpSubscriptions

protected void dumpSubscriptions()