public class TopicService extends Object implements ManagedService, RemoteService, EventPublishingService
Modifier and Type | Field and Description |
---|---|
static int |
ORDERING_LOCKS_LENGTH |
static String |
SERVICE_NAME |
Constructor and Description |
---|
TopicService() |
Modifier and Type | Method and Description |
---|---|
String |
addMessageListener(String name,
MessageListener listener) |
TopicProxy |
createDistributedObject(String name) |
void |
destroyDistributedObject(String objectId) |
void |
dispatchEvent(Object event,
Object listener) |
LocalTopicStatsImpl |
getLocalTopicStats(String name) |
Lock |
getOrderLock(String key) |
void |
incrementPublishes(String topicName) |
void |
incrementReceivedMessages(String topicName) |
void |
init(NodeEngine nodeEngine,
Properties properties)
Initializes the ManagedService
|
void |
publishEvent(String name,
TopicEvent event) |
boolean |
removeMessageListener(String name,
String registrationId) |
void |
reset()
reset service, back to initial state
|
void |
shutdown(boolean terminate)
Shuts down the ManagedService.
|
public static final String SERVICE_NAME
public static final int ORDERING_LOCKS_LENGTH
public void init(NodeEngine nodeEngine, Properties properties)
ManagedService
init
in interface ManagedService
nodeEngine
- the NodeEngine this ManagedService is initialized with.properties
- the Propertiespublic void reset()
ManagedService
reset
in interface ManagedService
public void shutdown(boolean terminate)
ManagedService
shutdown
in interface ManagedService
public TopicProxy createDistributedObject(String name)
createDistributedObject
in interface RemoteService
public void destroyDistributedObject(String objectId)
destroyDistributedObject
in interface RemoteService
public void dispatchEvent(Object event, Object listener)
dispatchEvent
in interface EventPublishingService
public LocalTopicStatsImpl getLocalTopicStats(String name)
public void incrementPublishes(String topicName)
public void incrementReceivedMessages(String topicName)
public void publishEvent(String name, TopicEvent event)
public String addMessageListener(String name, MessageListener listener)
Copyright © 2014 Hazelcast, Inc.. All rights reserved.