jp.go.aist.rtm.RTC.port.publisher
Class PublisherBase

java.lang.Object
  jp.go.aist.rtm.RTC.port.publisher.PublisherBase

Direct Known Subclasses:

PublisherFlush, PublisherNew, PublisherPeriodic

public abstract class PublisherBase
extends java.lang.Object

データ送出タイミングを管理して送出を駆動するPublisherのベース実装クラスです。

Constructor Summary

PublisherBase()

Method Summary

abstract ReturnCode	activate() activate
abstract ReturnCode	deactivate() deactivate
abstract java.lang.String	getName() getName
abstract ReturnCode	init(Properties prop) init
abstract boolean	isActive() isActive
void	release() 当該Publisherの駆動が停止される際に、PublisherFactoryにより呼び出されます。
abstract ReturnCode	setBuffer(BufferBase<org.omg.CORBA.portable.OutputStream> buffer) setBuffer
abstract ReturnCode	setConsumer(InPortConsumer consumer) setConsumer
abstract ReturnCode	setListener(ConnectorBase.ConnectorInfo info, ConnectorListeners listeners) Setting buffer pointer
abstract ReturnCode	write(org.omg.CORBA.portable.OutputStream data)
abstract ReturnCode	write(org.omg.CORBA.portable.OutputStream data, int sec, int usec) write

Methods inherited from class java.lang.Object

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

Constructor Detail

PublisherBase

public PublisherBase()

Method Detail

release

public void release()

当該Publisherの駆動が停止される際に、PublisherFactoryにより呼び出されます。

init

public abstract ReturnCode init(Properties prop)

init

Parameters:

prop -

Returns:

ReturnCode

setConsumer

public abstract ReturnCode setConsumer(InPortConsumer consumer)

setConsumer

Parameters:

consumer -

Returns:

ReturnCode

setBuffer

public abstract ReturnCode setBuffer(BufferBase<org.omg.CORBA.portable.OutputStream> buffer)

setBuffer

Parameters:

buffer -

Returns:

ReturnCode

write

public abstract ReturnCode write(org.omg.CORBA.portable.OutputStream data,
                                 int sec,
                                 int usec)

write

Parameters:

data -

sec -

usec -

Returns:

ReturnCode

write

public abstract ReturnCode write(org.omg.CORBA.portable.OutputStream data)

isActive

public abstract boolean isActive()

isActive

Returns:

boolean

activate

public abstract ReturnCode activate()

activate

Returns:

ReturnCode

deactivate

public abstract ReturnCode deactivate()

deactivate

Returns:

ReturnCode

getName

public abstract java.lang.String getName()

getName

Returns:

String

setListener

public abstract ReturnCode setListener(ConnectorBase.ConnectorInfo info,
                                       ConnectorListeners listeners)

Setting buffer pointer

Parameters:

info -

listeners -

Returns:

ReturnCode