public class PublishProv extends EvwSrvcBase implements SrvcProv
Publishes messages by topic.
Modifier and Type | Field and Description |
---|---|
static java.lang.String[] |
DEP_LIST
Class dependencies
|
static java.lang.String[] |
pubSubList |
static java.lang.String[] |
rsrcList
Supported resource requests
|
protected static java.lang.Integer[] |
SUPPORTED_MEDIA |
static java.lang.String[] |
tagList
Supported request tags
|
static java.lang.String |
VERSION
Class version
|
debugging, log, registry, tracingIo
IF_VERSION
IF_VERSION
Constructor and Description |
---|
PublishProv() |
Modifier and Type | Method and Description |
---|---|
boolean |
addSubscription(SrvrChan subscriber,
java.lang.String pubTopic) |
int |
dispatchRqst(TvList msgRec,
SrvrChan chnl,
java.lang.String[] srvrCmd)
Dispatch channel request.
|
protected void |
dumpSubscriptions() |
java.util.List |
getSupportedMedia()
Get the MIME types supported by the service.
|
java.util.List |
getSupportedTags()
Get the tags supported by the service.
|
java.util.List |
getSupportedValues(java.lang.String tag)
Get the values that are valid for a tag.
|
void |
handleDisconnect(SrvrChan client) |
void |
init(SrvcRegistry registry,
java.lang.String params)
Initialize the service.
|
void |
listSubscriptions(java.lang.String pubTopic,
java.io.PrintWriter toClient) |
int |
publish(TvList publication,
java.io.PrintWriter toPublisher) |
boolean |
removeSubscription(SrvrChan subscriber,
java.lang.String pubTopic) |
int |
suggestActivityTimeout()
Suggest an activity timeout for the service.
|
isDebugging, isTracingIo, setDebugging, setTracingIo
public static final java.lang.String VERSION
public static final java.lang.String[] DEP_LIST
public static final java.lang.String[] tagList
public static final java.lang.String[] rsrcList
public static final java.lang.String[] pubSubList
protected static final java.lang.Integer[] SUPPORTED_MEDIA
public void init(SrvcRegistry registry, java.lang.String params)
EvwSrvcBase
init
in interface RegInit
init
in class EvwSrvcBase
registry
- The service registryparams
- Configuration parameters for the servicepublic java.util.List getSupportedMedia()
SelfDescribing
getSupportedMedia
in interface SelfDescribing
MimeType
public java.util.List getSupportedTags()
SelfDescribing
getSupportedTags
in interface SelfDescribing
public java.util.List getSupportedValues(java.lang.String tag)
SelfDescribing
getSupportedValues
in interface SelfDescribing
tag
- The tag to get values for.public int suggestActivityTimeout()
SelfDescribing
suggestActivityTimeout
in interface SelfDescribing
public int dispatchRqst(TvList msgRec, SrvrChan chnl, java.lang.String[] srvrCmd)
dispatchRqst
in interface SrvcProv
public void handleDisconnect(SrvrChan client)
handleDisconnect
in interface SrvcProv
public int publish(TvList publication, java.io.PrintWriter toPublisher)
public boolean addSubscription(SrvrChan subscriber, java.lang.String pubTopic)
public boolean removeSubscription(SrvrChan subscriber, java.lang.String pubTopic)
public void listSubscriptions(java.lang.String pubTopic, java.io.PrintWriter toClient)
protected void dumpSubscriptions()