Package cz.o2.proxima.direct.io.pubsub

Class AbstractPubSubWriter

java.lang.Object

cz.o2.proxima.direct.io.pubsub.AbstractPubSubWriter

public class AbstractPubSubWriter
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
protected PubSubAccessor	accessor
protected Context	context

Constructor Summary

Constructors

Constructor	Description
AbstractPubSubWriter(PubSubAccessor accessor, Context context)

Method Summary

Modifier and Type	Method	Description
void	close()
java.net.URI	getUri()
protected void	writeMessage(java.lang.String messageId, long stamp, com.google.protobuf.Message msg, CommitCallback statusCallback)

Methods inherited from class java.lang.Object

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

Field Detail

accessor

protected final PubSubAccessor accessor

context

protected final Context context

Constructor Detail

AbstractPubSubWriter

public AbstractPubSubWriter(PubSubAccessor accessor,
                            Context context)

Method Detail

getUri

public java.net.URI getUri()

writeMessage

protected void writeMessage(java.lang.String messageId,
                            long stamp,
                            com.google.protobuf.Message msg,
                            CommitCallback statusCallback)

close

public void close()