public class MRvSink extends MSink
MRvSink
allows applications to send trace messages as
TIBCO Rendezvous messages.m_registry
Constructor and Description |
---|
MRvSink(MComponentRegistry registry,
java.lang.String name,
MRvSession session,
java.lang.String subject)
Create a sink by specifying an RV session object.
|
MRvSink(MComponentRegistry registry,
java.lang.String name,
java.lang.String sessionName,
java.lang.String subject)
Create a sink by specifying the session by name.
|
Modifier and Type | Method and Description |
---|---|
java.lang.String |
toString() |
void |
write(java.lang.String msg,
boolean flush)
Write the specified string message to the RV bus
|
void |
write(java.lang.String msgPrefix,
MTree tree,
boolean flush)
Serialize the specified MTree object to this sink.
|
closeSink, flushSink, write, write, write, write
activate, deactivate, getComponentRegistry, getName, getStatus, isActivated, remove
public MRvSink(MComponentRegistry registry, java.lang.String name, MRvSession session, java.lang.String subject)
MRvSink
is attached to a trace, all trace messages
are sent out as TIBCO Rendezvous messages.registry
- Component registry in which this file sink is being created. Use
MApp.getComponentRegistry()
to retrieve the component registry for an application.name
- Name of this MRvSink
.session
- Session in which this MRvSink
is created.subject
- Name of the subject on which this sink publishes messages.public MRvSink(MComponentRegistry registry, java.lang.String name, java.lang.String sessionName, java.lang.String subject)
MRvSink
is attached to a trace, all trace messages
are sent out as TIBCO Rendezvous messages.registry
- Component registry in which this file sink is being created. Use
app.getComponentRegistry()
to retrieve the component registry for an application.name
- Name of this MRvSink
.sessionName
- Session in which this MRvSink
is created.subject
- Name of the subject on which this sink publishes messages.public void write(java.lang.String msg, boolean flush)
public void write(java.lang.String msgPrefix, MTree tree, boolean flush)