Package com.hazelcast.console
Class ConsoleApp
- java.lang.Object
-
- com.hazelcast.console.ConsoleApp
-
- All Implemented Interfaces:
ItemListener<java.lang.Object>
,EntryListener<java.lang.Object,java.lang.Object>
,EntryAddedListener<java.lang.Object,java.lang.Object>
,EntryEvictedListener<java.lang.Object,java.lang.Object>
,EntryExpiredListener<java.lang.Object,java.lang.Object>
,EntryRemovedListener<java.lang.Object,java.lang.Object>
,EntryUpdatedListener<java.lang.Object,java.lang.Object>
,MapClearedListener
,MapEvictedListener
,MapListener
,MessageListener<java.lang.Object>
,java.util.EventListener
public class ConsoleApp extends java.lang.Object implements EntryListener<java.lang.Object,java.lang.Object>, ItemListener<java.lang.Object>, MessageListener<java.lang.Object>
Special thanks to Alexandre Vasseur for providing this very nice test application.
-
-
Constructor Summary
Constructors Constructor Description ConsoleApp(HazelcastInstance hazelcast, java.io.PrintStream outOrig)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description protected static ConsoleApp
create()
void
entryAdded(EntryEvent event)
Invoked upon addition of an entry.void
entryEvicted(EntryEvent event)
Invoked upon eviction of an entry.void
entryExpired(EntryEvent<java.lang.Object,java.lang.Object> event)
Invoked upon expiration of an entry.void
entryRemoved(EntryEvent event)
Invoked upon removal of an entry.void
entryUpdated(EntryEvent event)
Invoked upon update of an entry.IAtomicLong
getAtomicNumber()
IList<java.lang.Object>
getList()
IMap<java.lang.Object,java.lang.Object>
getMap()
MultiMap<java.lang.Object,java.lang.Object>
getMultiMap()
IQueue<java.lang.Object>
getQueue()
ISet<java.lang.Object>
getSet()
ITopic<java.lang.Object>
getTopic()
protected void
handleAddListener(java.lang.String[] args)
protected void
handleClear(java.lang.String[] args)
void
handleCommand(java.lang.String inputCommand)
Handles a command.protected void
handleContains(java.lang.String[] args)
protected void
handleDestroy(java.lang.String[] args)
protected void
handleExit()
protected void
handleInstances(java.lang.String[] args)
protected void
handleIterator(java.lang.String[] args)
protected void
handleListAdd(java.lang.String[] args)
protected void
handleListAddMany(java.lang.String[] args)
protected void
handleListContains(java.lang.String[] args)
protected void
handleListRemove(java.lang.String[] args)
protected void
handleListSet(java.lang.String[] args)
protected void
handleLock(java.lang.String[] args)
protected void
handleMapDelete(java.lang.String[] args)
protected void
handleMapEntries()
protected void
handleMapEvict(java.lang.String[] args)
protected void
handleMapGet(java.lang.String[] args)
protected void
handleMapGetAsync(java.lang.String[] args)
protected void
handleMapGetMany(java.lang.String[] args)
protected void
handleMapGetMapEntry(java.lang.String[] args)
protected void
handleMapKeys()
protected void
handleMapLocalKeys()
protected void
handleMapLocalSize()
protected void
handleMapLock(java.lang.String[] args)
protected void
handleMapPut(java.lang.String[] args)
protected void
handleMapPutAsync(java.lang.String[] args)
protected void
handleMapPutIfAbsent(java.lang.String[] args)
protected void
handleMapPutMany(java.lang.String[] args)
protected void
handleMapRemove(java.lang.String[] args)
protected void
handleMapRemoveMany(java.lang.String[] args)
protected void
handleMapReplace(java.lang.String[] args)
protected void
handleMapTryLock(java.lang.String[] args)
protected void
handleMapUnlock(java.lang.String[] args)
protected void
handleMapValues()
protected void
handleMultiMapEntries()
protected void
handleMultiMapGet(java.lang.String[] args)
protected void
handleMultiMapKeys()
protected void
handleMultiMapLock(java.lang.String[] args)
protected void
handleMultiMapPut(java.lang.String[] args)
protected void
handleMultiMapRemove(java.lang.String[] args)
protected void
handleMultiMapTryLock(java.lang.String[] args)
protected void
handleMultiMapUnlock(java.lang.String[] args)
protected void
handleMultiMapValues()
protected void
handlePartitions(java.lang.String[] args)
protected void
handleQCapacity(java.lang.String[] args)
protected void
handleQOffer(java.lang.String[] args)
protected void
handleQOfferMany(java.lang.String[] args)
protected void
handleQPeek(java.lang.String[] args)
protected void
handleQPoll(java.lang.String[] args)
protected void
handleQPollMany(java.lang.String[] args)
protected void
handleQTake(java.lang.String[] args)
protected void
handleRemoveListener(java.lang.String[] args)
protected void
handleSetAdd(java.lang.String[] args)
protected void
handleSetAddMany(java.lang.String[] args)
protected void
handleSetRemove(java.lang.String[] args)
protected void
handleSetRemoveMany(java.lang.String[] args)
protected void
handleShutdown()
protected void
handleSize(java.lang.String[] args)
protected void
handleTopicPublish(java.lang.String[] args)
protected boolean
isRunning()
void
itemAdded(ItemEvent itemEvent)
Invoked when an item is added.void
itemRemoved(ItemEvent itemEvent)
Invoked when an item is removed.static void
main(java.lang.String[] args)
Starts the test application.void
mapCleared(MapEvent event)
Invoked when all entries are removed byIMap.clear()
.void
mapEvicted(MapEvent event)
Invoked when all entries are evicted byIMap.evictAll()
.void
onMessage(Message msg)
Invoked when a message is received for the topic.void
print(java.lang.Object obj)
void
println(java.lang.Object obj)
void
start()
void
stop()
-
-
-
Constructor Detail
-
ConsoleApp
public ConsoleApp(HazelcastInstance hazelcast, java.io.PrintStream outOrig)
-
-
Method Detail
-
getQueue
public IQueue<java.lang.Object> getQueue()
-
getTopic
public ITopic<java.lang.Object> getTopic()
-
getMap
public IMap<java.lang.Object,java.lang.Object> getMap()
-
getMultiMap
public MultiMap<java.lang.Object,java.lang.Object> getMultiMap()
-
getAtomicNumber
public IAtomicLong getAtomicNumber()
-
getSet
public ISet<java.lang.Object> getSet()
-
getList
public IList<java.lang.Object> getList()
-
stop
public void stop()
-
start
public void start() throws java.lang.Exception
- Throws:
java.lang.Exception
-
handleCommand
public void handleCommand(java.lang.String inputCommand)
Handles a command.
-
handleShutdown
protected void handleShutdown()
-
handleExit
protected void handleExit()
-
handlePartitions
protected void handlePartitions(java.lang.String[] args)
-
handleInstances
protected void handleInstances(java.lang.String[] args)
-
handleListContains
protected void handleListContains(java.lang.String[] args)
-
handleListRemove
protected void handleListRemove(java.lang.String[] args)
-
handleListAdd
protected void handleListAdd(java.lang.String[] args)
-
handleListSet
protected void handleListSet(java.lang.String[] args)
-
handleListAddMany
protected void handleListAddMany(java.lang.String[] args)
-
handleMapPut
protected void handleMapPut(java.lang.String[] args)
-
handleMapPutAsync
protected void handleMapPutAsync(java.lang.String[] args)
-
handleMapPutIfAbsent
protected void handleMapPutIfAbsent(java.lang.String[] args)
-
handleMapReplace
protected void handleMapReplace(java.lang.String[] args)
-
handleMapGet
protected void handleMapGet(java.lang.String[] args)
-
handleMapGetAsync
protected void handleMapGetAsync(java.lang.String[] args)
-
handleMapGetMapEntry
protected void handleMapGetMapEntry(java.lang.String[] args)
-
handleMapRemove
protected void handleMapRemove(java.lang.String[] args)
-
handleMapDelete
protected void handleMapDelete(java.lang.String[] args)
-
handleMapEvict
protected void handleMapEvict(java.lang.String[] args)
-
handleMapPutMany
protected void handleMapPutMany(java.lang.String[] args)
-
handleMapGetMany
protected void handleMapGetMany(java.lang.String[] args)
-
handleMapRemoveMany
protected void handleMapRemoveMany(java.lang.String[] args)
-
handleMapLock
protected void handleMapLock(java.lang.String[] args)
-
handleMapTryLock
protected void handleMapTryLock(java.lang.String[] args)
-
handleMapUnlock
protected void handleMapUnlock(java.lang.String[] args)
-
handleMapLocalKeys
protected void handleMapLocalKeys()
-
handleMapLocalSize
protected void handleMapLocalSize()
-
handleMapKeys
protected void handleMapKeys()
-
handleMapEntries
protected void handleMapEntries()
-
handleMapValues
protected void handleMapValues()
-
handleMultiMapPut
protected void handleMultiMapPut(java.lang.String[] args)
-
handleMultiMapGet
protected void handleMultiMapGet(java.lang.String[] args)
-
handleMultiMapRemove
protected void handleMultiMapRemove(java.lang.String[] args)
-
handleMultiMapKeys
protected void handleMultiMapKeys()
-
handleMultiMapEntries
protected void handleMultiMapEntries()
-
handleMultiMapValues
protected void handleMultiMapValues()
-
handleMultiMapLock
protected void handleMultiMapLock(java.lang.String[] args)
-
handleMultiMapTryLock
protected void handleMultiMapTryLock(java.lang.String[] args)
-
handleMultiMapUnlock
protected void handleMultiMapUnlock(java.lang.String[] args)
-
handleLock
protected void handleLock(java.lang.String[] args)
-
handleAddListener
protected void handleAddListener(java.lang.String[] args)
-
handleRemoveListener
protected void handleRemoveListener(java.lang.String[] args)
-
handleSetAdd
protected void handleSetAdd(java.lang.String[] args)
-
handleSetRemove
protected void handleSetRemove(java.lang.String[] args)
-
handleSetAddMany
protected void handleSetAddMany(java.lang.String[] args)
-
handleSetRemoveMany
protected void handleSetRemoveMany(java.lang.String[] args)
-
handleIterator
protected void handleIterator(java.lang.String[] args)
-
handleContains
protected void handleContains(java.lang.String[] args)
-
handleSize
protected void handleSize(java.lang.String[] args)
-
handleClear
protected void handleClear(java.lang.String[] args)
-
handleDestroy
protected void handleDestroy(java.lang.String[] args)
-
handleQOffer
protected void handleQOffer(java.lang.String[] args)
-
handleQTake
protected void handleQTake(java.lang.String[] args)
-
handleQPoll
protected void handleQPoll(java.lang.String[] args)
-
handleTopicPublish
protected void handleTopicPublish(java.lang.String[] args)
-
handleQOfferMany
protected void handleQOfferMany(java.lang.String[] args)
-
handleQPollMany
protected void handleQPollMany(java.lang.String[] args)
-
handleQPeek
protected void handleQPeek(java.lang.String[] args)
-
handleQCapacity
protected void handleQCapacity(java.lang.String[] args)
-
entryAdded
public void entryAdded(EntryEvent event)
Description copied from interface:EntryAddedListener
Invoked upon addition of an entry.- Specified by:
entryAdded
in interfaceEntryAddedListener<java.lang.Object,java.lang.Object>
- Parameters:
event
- the event invoked when an entry is added
-
entryRemoved
public void entryRemoved(EntryEvent event)
Description copied from interface:EntryRemovedListener
Invoked upon removal of an entry.- Specified by:
entryRemoved
in interfaceEntryRemovedListener<java.lang.Object,java.lang.Object>
- Parameters:
event
- the event invoked when an entry is removed
-
entryUpdated
public void entryUpdated(EntryEvent event)
Description copied from interface:EntryUpdatedListener
Invoked upon update of an entry.- Specified by:
entryUpdated
in interfaceEntryUpdatedListener<java.lang.Object,java.lang.Object>
- Parameters:
event
- the event invoked when an entry is updated
-
entryEvicted
public void entryEvicted(EntryEvent event)
Description copied from interface:EntryEvictedListener
Invoked upon eviction of an entry.- Specified by:
entryEvicted
in interfaceEntryEvictedListener<java.lang.Object,java.lang.Object>
- Parameters:
event
- the event invoked when an entry is evicted
-
entryExpired
public void entryExpired(EntryEvent<java.lang.Object,java.lang.Object> event)
Description copied from interface:EntryExpiredListener
Invoked upon expiration of an entry.- Specified by:
entryExpired
in interfaceEntryExpiredListener<java.lang.Object,java.lang.Object>
- Parameters:
event
- the event invoked when an entry is expired.
-
mapEvicted
public void mapEvicted(MapEvent event)
Description copied from interface:MapEvictedListener
Invoked when all entries are evicted byIMap.evictAll()
.- Specified by:
mapEvicted
in interfaceMapEvictedListener
- Parameters:
event
- the map event invoked when all entries are evicted byIMap.evictAll()
-
mapCleared
public void mapCleared(MapEvent event)
Description copied from interface:MapClearedListener
Invoked when all entries are removed byIMap.clear()
. When a listener is registered as local-only then it will be invoked if and only if theclear()
method is called on the same instance where the listener was registered to.- Specified by:
mapCleared
in interfaceMapClearedListener
- Parameters:
event
- the map event invoked when all entries are removed byIMap.clear()
-
itemAdded
public void itemAdded(ItemEvent itemEvent)
Description copied from interface:ItemListener
Invoked when an item is added.- Specified by:
itemAdded
in interfaceItemListener<java.lang.Object>
- Parameters:
itemEvent
- the added item
-
itemRemoved
public void itemRemoved(ItemEvent itemEvent)
Description copied from interface:ItemListener
Invoked when an item is removed.- Specified by:
itemRemoved
in interfaceItemListener<java.lang.Object>
- Parameters:
itemEvent
- the removed item.
-
onMessage
public void onMessage(Message msg)
Description copied from interface:MessageListener
Invoked when a message is received for the topic. Note that the topic guarantees message ordering. Therefore there is only one thread invoking onMessage. The user should not keep the thread busy, but preferably should dispatch it via an Executor. This will increase the performance of the topic.- Specified by:
onMessage
in interfaceMessageListener<java.lang.Object>
- Parameters:
msg
- the message that is received for the topic
-
println
public void println(java.lang.Object obj)
-
print
public void print(java.lang.Object obj)
-
isRunning
protected boolean isRunning()
-
create
protected static ConsoleApp create() throws java.lang.Exception
- Throws:
java.lang.Exception
-
main
public static void main(java.lang.String[] args) throws java.lang.Exception
Starts the test application.It loads the Hazelcast member configuration using the resolution logic as described in
Hazelcast.newHazelcastInstance()
.- Throws:
java.lang.Exception
- in case of any exceptional case
-
-