Package com.hazelcast.console

Class ConsoleApp

    • 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 interface EntryAddedListener<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 interface EntryRemovedListener<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 interface EntryUpdatedListener<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 interface EntryEvictedListener<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 interface EntryExpiredListener<java.lang.Object,​java.lang.Object>
        Parameters:
        event - the event invoked when an entry is expired.

      • 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<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 interface ItemListener<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 interface MessageListener<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