Package org.fisco.bcos.sdk.amop.topic

Class TopicManager

java.lang.Object

org.fisco.bcos.sdk.amop.topic.TopicManager

public class TopicManager
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	pushChannelPrefix
static java.lang.String	topicNeedVerifyPrefix
static java.lang.String	verifyChannelPrefix

Constructor Summary

Constructors

Constructor	Description
TopicManager()

Method Summary

Modifier and Type	Method	Description
void	addPrivateTopicCallback(java.lang.String topicName, AmopCallback callback)
void	addPrivateTopicSend(java.lang.String topicName, java.util.List<KeyTool> publicKeyTools)
void	addPrivateTopicSubscribe(java.lang.String topicName, KeyTool privateKeyStore, AmopCallback callback)
void	addTopic(java.lang.String topicString, AmopCallback callback)
boolean	canSendTopicMsg(AmopMsgOut out)
java.util.Set<java.lang.String>	getAllTopics()
java.util.Set<java.lang.String>	getBlockNotifyByPeer(java.lang.String peerIpPort)
AmopCallback	getCallback(java.lang.String topicName)
java.lang.String	getFullTopicString(java.lang.String topicName)
KeyTool	getPrivateKeyByTopic(java.lang.String topic)
java.util.List<KeyTool>	getPublicKeysByTopic(java.lang.String topic)
java.util.Set<java.lang.String>	getSubByPeer(java.lang.String peerIpPort)
java.util.Set<java.lang.String>	getTopicNames()
boolean	isSubTopic(java.lang.String topic)
void	removeTopic(java.lang.String topicName)	Make sure do not use same name of a normal and a private topic remove the topic
void	setCallback(AmopCallback cb)
void	updateBlockNotify(java.lang.String peerIpPort, java.util.List<java.lang.String> groupInfo)
void	updatePrivateTopicUUID()

Methods inherited from class java.lang.Object

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

Field Details

verifyChannelPrefix

public static final java.lang.String verifyChannelPrefix

See Also:

Constant Field Values

pushChannelPrefix

public static final java.lang.String pushChannelPrefix

See Also:

Constant Field Values

topicNeedVerifyPrefix

public static final java.lang.String topicNeedVerifyPrefix

See Also:

Constant Field Values

Constructor Details

TopicManager

public TopicManager()

Method Details

addTopic

public void addTopic(java.lang.String topicString, AmopCallback callback)

addPrivateTopicSubscribe

public void addPrivateTopicSubscribe(java.lang.String topicName, KeyTool privateKeyStore, AmopCallback callback)

addPrivateTopicSend

public void addPrivateTopicSend(java.lang.String topicName, java.util.List<KeyTool> publicKeyTools)

addPrivateTopicCallback

public void addPrivateTopicCallback(java.lang.String topicName, AmopCallback callback)

removeTopic

public void removeTopic(java.lang.String topicName)

Make sure do not use same name of a normal and a private topic remove the topic

Parameters:

topicName - the topic name

getSubByPeer

public java.util.Set<java.lang.String> getSubByPeer(java.lang.String peerIpPort)

getBlockNotifyByPeer

public java.util.Set<java.lang.String> getBlockNotifyByPeer(java.lang.String peerIpPort)

getTopicNames

public java.util.Set<java.lang.String> getTopicNames()

updateBlockNotify

public void updateBlockNotify(java.lang.String peerIpPort, java.util.List<java.lang.String> groupInfo)

getCallback

public AmopCallback getCallback(java.lang.String topicName)

getFullTopicString

public java.lang.String getFullTopicString(java.lang.String topicName)

setCallback

public void setCallback(AmopCallback cb)

getPublicKeysByTopic

public java.util.List<KeyTool> getPublicKeysByTopic(java.lang.String topic)

getPrivateKeyByTopic

public KeyTool getPrivateKeyByTopic(java.lang.String topic)

isSubTopic

public boolean isSubTopic(java.lang.String topic)

canSendTopicMsg

public boolean canSendTopicMsg(AmopMsgOut out)

updatePrivateTopicUUID

public void updatePrivateTopicUUID()

getAllTopics

public java.util.Set<java.lang.String> getAllTopics()