ConsoleApp (Hazelcast Root 5.1.4 API)

java.lang.Object
- com.hazelcast.console.ConsoleApp

All Implemented Interfaces:

ItemListener<Object>, EntryListener<Object,Object>, EntryAddedListener<Object,Object>, EntryEvictedListener<Object,Object>, EntryExpiredListener<Object,Object>, EntryRemovedListener<Object,Object>, EntryUpdatedListener<Object,Object>, MapClearedListener, MapEvictedListener, MapListener, MessageListener<Object>, EventListener
```
public class ConsoleApp
extends Object
implements EntryListener<Object,Object>, ItemListener<Object>, MessageListener<Object>
```
Special thanks to Alexandre Vasseur for providing this very nice test application.

Constructor Summary

Constructors
Constructor and Description

ConsoleApp(HazelcastInstance hazelcast, PrintStream outOrig)

Constructors
Constructor and Description
`ConsoleApp(HazelcastInstance hazelcast, PrintStream outOrig)`

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and 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<Object,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<Object>`	`getList()`
`IMap<Object,Object>`	`getMap()`
`MultiMap<Object,Object>`	`getMultiMap()`
`IQueue<Object>`	`getQueue()`
`ISet<Object>`	`getSet()`
`ITopic<Object>`	`getTopic()`
`protected void`	`handleAddListener(String[] args)`
`protected void`	`handleClear(String[] args)`
`void`	`handleCommand(String inputCommand)` Handles a command.
`protected void`	`handleContains(String[] args)`
`protected void`	`handleDestroy(String[] args)`
`protected void`	`handleExit()`
`protected void`	`handleInstances(String[] args)`
`protected void`	`handleIterator(String[] args)`
`protected void`	`handleListAdd(String[] args)`
`protected void`	`handleListAddMany(String[] args)`
`protected void`	`handleListContains(String[] args)`
`protected void`	`handleListRemove(String[] args)`
`protected void`	`handleListSet(String[] args)`
`protected void`	`handleLock(String[] args)`
`protected void`	`handleMapDelete(String[] args)`
`protected void`	`handleMapEntries()`
`protected void`	`handleMapEvict(String[] args)`
`protected void`	`handleMapGet(String[] args)`
`protected void`	`handleMapGetAsync(String[] args)`
`protected void`	`handleMapGetMany(String[] args)`
`protected void`	`handleMapGetMapEntry(String[] args)`
`protected void`	`handleMapKeys()`
`protected void`	`handleMapLocalKeys()`
`protected void`	`handleMapLocalSize()`
`protected void`	`handleMapLock(String[] args)`
`protected void`	`handleMapPut(String[] args)`
`protected void`	`handleMapPutAsync(String[] args)`
`protected void`	`handleMapPutIfAbsent(String[] args)`
`protected void`	`handleMapPutMany(String[] args)`
`protected void`	`handleMapRemove(String[] args)`
`protected void`	`handleMapRemoveMany(String[] args)`
`protected void`	`handleMapReplace(String[] args)`
`protected void`	`handleMapTryLock(String[] args)`
`protected void`	`handleMapUnlock(String[] args)`
`protected void`	`handleMapValues()`
`protected void`	`handleMultiMapEntries()`
`protected void`	`handleMultiMapGet(String[] args)`
`protected void`	`handleMultiMapKeys()`
`protected void`	`handleMultiMapLock(String[] args)`
`protected void`	`handleMultiMapPut(String[] args)`
`protected void`	`handleMultiMapRemove(String[] args)`
`protected void`	`handleMultiMapTryLock(String[] args)`
`protected void`	`handleMultiMapUnlock(String[] args)`
`protected void`	`handleMultiMapValues()`
`protected void`	`handlePartitions(String[] args)`
`protected void`	`handleQCapacity(String[] args)`
`protected void`	`handleQOffer(String[] args)`
`protected void`	`handleQOfferMany(String[] args)`
`protected void`	`handleQPeek(String[] args)`
`protected void`	`handleQPoll(String[] args)`
`protected void`	`handleQPollMany(String[] args)`
`protected void`	`handleQTake(String[] args)`
`protected void`	`handleRemoveListener(String[] args)`
`protected void`	`handleSetAdd(String[] args)`
`protected void`	`handleSetAddMany(String[] args)`
`protected void`	`handleSetRemove(String[] args)`
`protected void`	`handleSetRemoveMany(String[] args)`
`protected void`	`handleShutdown()`
`protected void`	`handleSize(String[] args)`
`protected void`	`handleTopicPublish(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(String[] args)` Starts the test application.
`void`	`mapCleared(MapEvent event)` Invoked when all entries are removed by `IMap.clear()`.
`void`	`mapEvicted(MapEvent event)` Invoked when all entries are evicted by `IMap.evictAll()`.
`void`	`onMessage(Message msg)` Invoked when a message is received for the topic.
`void`	`print(Object obj)`
`void`	`println(Object obj)`
`void`	`start()`
`void`	`stop()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - ConsoleApp
```
public ConsoleApp(HazelcastInstance hazelcast,
                  PrintStream outOrig)
```
- Method Detail
  - getQueue
```
public IQueue<Object> getQueue()
```
  - getTopic
```
public ITopic<Object> getTopic()
```
  - getMap
```
public IMap<Object,Object> getMap()
```
  - getMultiMap
```
public MultiMap<Object,Object> getMultiMap()
```
  - getAtomicNumber
```
public IAtomicLong getAtomicNumber()
```
  - getSet
```
public ISet<Object> getSet()
```
  - getList
```
public IList<Object> getList()
```
  - stop
```
public void stop()
```
  - start
```
public void start()
           throws Exception
```
    Throws:
    
    Exception
  - handleCommand
```
public void handleCommand(String inputCommand)
```
    Handles a command.
  - handleShutdown
```
protected void handleShutdown()
```
  - handleExit
```
protected void handleExit()
```
  - handlePartitions
```
protected void handlePartitions(String[] args)
```
  - handleInstances
```
protected void handleInstances(String[] args)
```
  - handleListContains
```
protected void handleListContains(String[] args)
```
  - handleListRemove
```
protected void handleListRemove(String[] args)
```
  - handleListAdd
```
protected void handleListAdd(String[] args)
```
  - handleListSet
```
protected void handleListSet(String[] args)
```
  - handleListAddMany
```
protected void handleListAddMany(String[] args)
```
  - handleMapPut
```
protected void handleMapPut(String[] args)
```
  - handleMapPutAsync
```
protected void handleMapPutAsync(String[] args)
```
  - handleMapPutIfAbsent
```
protected void handleMapPutIfAbsent(String[] args)
```
  - handleMapReplace
```
protected void handleMapReplace(String[] args)
```
  - handleMapGet
```
protected void handleMapGet(String[] args)
```
  - handleMapGetAsync
```
protected void handleMapGetAsync(String[] args)
```
  - handleMapGetMapEntry
```
protected void handleMapGetMapEntry(String[] args)
```
  - handleMapRemove
```
protected void handleMapRemove(String[] args)
```
  - handleMapDelete
```
protected void handleMapDelete(String[] args)
```
  - handleMapEvict
```
protected void handleMapEvict(String[] args)
```
  - handleMapPutMany
```
protected void handleMapPutMany(String[] args)
```
  - handleMapGetMany
```
protected void handleMapGetMany(String[] args)
```
  - handleMapRemoveMany
```
protected void handleMapRemoveMany(String[] args)
```
  - handleMapLock
```
protected void handleMapLock(String[] args)
```
  - handleMapTryLock
```
protected void handleMapTryLock(String[] args)
```
  - handleMapUnlock
```
protected void handleMapUnlock(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(String[] args)
```
  - handleMultiMapGet
```
protected void handleMultiMapGet(String[] args)
```
  - handleMultiMapRemove
```
protected void handleMultiMapRemove(String[] args)
```
  - handleMultiMapKeys
```
protected void handleMultiMapKeys()
```
  - handleMultiMapEntries
```
protected void handleMultiMapEntries()
```
  - handleMultiMapValues
```
protected void handleMultiMapValues()
```
  - handleMultiMapLock
```
protected void handleMultiMapLock(String[] args)
```
  - handleMultiMapTryLock
```
protected void handleMultiMapTryLock(String[] args)
```
  - handleMultiMapUnlock
```
protected void handleMultiMapUnlock(String[] args)
```
  - handleLock
```
protected void handleLock(String[] args)
```
  - handleAddListener
```
protected void handleAddListener(String[] args)
```
  - handleRemoveListener
```
protected void handleRemoveListener(String[] args)
```
  - handleSetAdd
```
protected void handleSetAdd(String[] args)
```
  - handleSetRemove
```
protected void handleSetRemove(String[] args)
```
  - handleSetAddMany
```
protected void handleSetAddMany(String[] args)
```
  - handleSetRemoveMany
```
protected void handleSetRemoveMany(String[] args)
```
  - handleIterator
```
protected void handleIterator(String[] args)
```
  - handleContains
```
protected void handleContains(String[] args)
```
  - handleSize
```
protected void handleSize(String[] args)
```
  - handleClear
```
protected void handleClear(String[] args)
```
  - handleDestroy
```
protected void handleDestroy(String[] args)
```
  - handleQOffer
```
protected void handleQOffer(String[] args)
```
  - handleQTake
```
protected void handleQTake(String[] args)
```
  - handleQPoll
```
protected void handleQPoll(String[] args)
```
  - handleTopicPublish
```
protected void handleTopicPublish(String[] args)
```
  - handleQOfferMany
```
protected void handleQOfferMany(String[] args)
```
  - handleQPollMany
```
protected void handleQPollMany(String[] args)
```
  - handleQPeek
```
protected void handleQPeek(String[] args)
```
  - handleQCapacity
```
protected void handleQCapacity(String[] args)
```
  - entryAdded
```
public void entryAdded(EntryEvent event)
```
    Description copied from interface: EntryAddedListener
    
    Invoked upon addition of an entry.
    
    Specified by:
    
    entryAdded in interface EntryAddedListener<Object,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 interface EntryRemovedListener<Object,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 interface EntryUpdatedListener<Object,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 interface EntryEvictedListener<Object,Object>
    
    Parameters:
    
    event - the event invoked when an entry is evicted
  - entryExpired
```
public void entryExpired(EntryEvent<Object,Object> event)
```
    Description copied from interface: EntryExpiredListener
    
    Invoked upon expiration of an entry.
    
    Specified by:
    
    entryExpired in interface EntryExpiredListener<Object,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 by IMap.evictAll().
    
    Specified by:
    
    mapEvicted in interface MapEvictedListener
    
    Parameters:
    
    event - the map event invoked when all entries are evicted by IMap.evictAll()
  - mapCleared
```
public void mapCleared(MapEvent event)
```
    Description copied from interface: MapClearedListener
    
    Invoked when all entries are removed by IMap.clear(). When a listener is registered as local-only then it will be invoked if and only if the clear() method is called on the same instance where the listener was registered to.
    
    Specified by:
    
    mapCleared in interface MapClearedListener
    
    Parameters:
    
    event - the map event invoked when all entries are removed by IMap.clear()
  - itemAdded
```
public void itemAdded(ItemEvent itemEvent)
```
    Description copied from interface: ItemListener
    
    Invoked when an item is added.
    
    Specified by:
    
    itemAdded in interface ItemListener<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 interface ItemListener<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 interface MessageListener<Object>
    
    Parameters:
    
    msg - the message that is received for the topic
  - println
```
public void println(Object obj)
```
  - print
```
public void print(Object obj)
```
  - isRunning
```
protected boolean isRunning()
```
  - create
```
protected static ConsoleApp create()
                            throws Exception
```
    Throws:
    
    Exception
  - main
```
public static void main(String[] args)
                 throws Exception
```
    Starts the test application.
    It loads the Hazelcast member configuration using the resolution logic as described in Hazelcast.newHazelcastInstance().
    
    Throws:
    
    Exception - in case of any exceptional case

Class ConsoleApp

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

ConsoleApp

Method Detail

getQueue

getTopic

getMap

getMultiMap

getAtomicNumber

getSet

getList

stop

start

handleCommand

handleShutdown

handleExit

handlePartitions

handleInstances

handleListContains

handleListRemove

handleListAdd

handleListSet

handleListAddMany

handleMapPut

handleMapPutAsync

handleMapPutIfAbsent

handleMapReplace

handleMapGet

handleMapGetAsync

handleMapGetMapEntry

handleMapRemove

handleMapDelete

handleMapEvict

handleMapPutMany

handleMapGetMany

handleMapRemoveMany

handleMapLock

handleMapTryLock

handleMapUnlock

handleMapLocalKeys

handleMapLocalSize

handleMapKeys

handleMapEntries

handleMapValues

handleMultiMapPut

handleMultiMapGet

handleMultiMapRemove

handleMultiMapKeys

handleMultiMapEntries

handleMultiMapValues

handleMultiMapLock

handleMultiMapTryLock

handleMultiMapUnlock

handleLock

handleAddListener

handleRemoveListener

handleSetAdd

handleSetRemove

handleSetAddMany

handleSetRemoveMany

handleIterator

handleContains

handleSize

handleClear

handleDestroy

handleQOffer

handleQTake

handleQPoll

handleTopicPublish

handleQOfferMany

handleQPollMany

handleQPeek

handleQCapacity

entryAdded

entryRemoved

entryUpdated

entryEvicted