info log removed in CQLBasedMessageStoreImpl
Merge pull request #210 from indikasampath2000/performance

info log removed in CQLBasedMessageStoreImpl
Inbound event handling with Disruptor

- Introduced Andes class for all Andes related interactions from outside. This works as a facade
  for MessagingEngine SubscriptionManager and AndesContextInformation Manager

- All the events coming to Andes are directed to a Disruptor ringBuffer. And then handled by relevant
  Event handlers and directed to relevant entity within Andes. ( e.g.: MessagingEngine, SubscriptionManager)

- Introduced AndesMessage class to wrap AndesMessageMetadata and AndesMessagePart. Andes only accept
  AndesMessages when receiving messages. No separate methods to handle message parts and message meta data
  at Andes level. This is to avoid unwanted complexity in handling a message as two separated entities.

- Disruptor has four event handlers types to handle events.
    - MessagePreProcessor:
          This event handler goes through the ring buffer first. Updates the message routing information if
          necessary. Specially for topics if message cloning needed clones the messages and Updated the
          AndesMessage list in the same position in ring buffer.

    - ConcurrentMessageWriter:
          There are multiple message writers that goes through the ring buffer after message pre processor
          This writes messages to the data base. All the necessary information is updated by message pre
          processor.

    - AckHandler:
          Acknowledgement related database update and state changes handle by this. There are multiple ack
          handlers that run in parallel after the MessagePreProcessor. ConcurrentMessageWriters and AckHandlers
          run in parallel

    - StateEventHandler:
          All the Andes state changes related logic, except for the acknowledgement handling logic, is handled
          through this event handler. e.g.: slot update logic for incoming new messages, channel open event
          This even handler goes through the list after all the event handlers have processed a slot in
          ring buffer.
Scheduled tasks moved to MessagingEngine

- Content removal task and message counter update tasks moved to MessagingEngine.
- Removed unwanted wait time for content removal task (we use a different logic to
  remove content for topic now)
- Added content clearing after processing InboundEvent objects in ring buffer.
Configuration options added :wrench:

configuration options added to tune the Disruptor based inbound event handling.

Following parameters can be configured from broker.xml
 - Concurrent message writer count
 - Concurrent ack handler count
 - Ring buffer size
Concurrent locks removed from inbound event path :unlock:

- Lock free message id generator implemented from TimeStampBasedMessageIdGenerator logic
  for MessagePreProcessor message ids

- SlotMessageCounter unwanted synchronizations removed. Since this is accessed from one thread now
Message id Reference Start value issue fixed :beetle:

- Negative value message id generation due to wrong value set for reference start is fixed.
- Added logic to clear InboundEvent data after handling acks as well
Custom batch event processor for inbound events

- Custom batch event processor with configurable batch size added to process
  concurrent message writing and acknowledgement handling.
Code Cleanup :sparkles:

- Code indentation issues fixed
- comments added
-
Merge pull request #211 from Asitha/disruptor-inbound-event

Disruptor based inbound event handling implementation
tracking data not removing logic re-write in SlotDeliveryWorker
# Please enter the commit message for your changes. Lines starting
# with '#' will be ignored, and an empty message aborts the commit.
# On branch performance
# Changes to be committed:
#	modified:   modules/andes-core/broker/src/main/java/org/wso2/andes/server/cassandra/OnflightMessageTracker.java
#	modified:   modules/andes-core/broker/src/main/java/org/wso2/andes/store/cassandra/cql/CQLBasedMessageStoreImpl.java
#
# Untracked files:
#	modules/andes-core/management/eclipse-plugin/.attach_pid27082
#	modules/andes-core/perftests/.attach_pid27197
#	modules/andes-core/systests/.attach_pid27105
#	modules/gentools/src/.attach_pid23923
#
Merge pull request #212 from indikasampath2000/performance

Tracking data removing logic re-write in SlotDeliveryWorker
Fix for ContentRemovalTask concurrent modification issue :beetle:

Replaced synchronised ArrayList with a ConcurrentHashMap
Merge pull request #213 from Asitha/content-removal-task

Fix for ContentRemovalTask concurrent modification issue
Returning empty array list if 'clusterTopicSubscriptionMap' is empty on 'getAllSubscribersForDestination'
Some of tracking data not removing issue fixed and trace logs added
Merge pull request #214 from indikasampath2000/performance

Some of tracking data not removing issue fixed and trace logs added
Inbound event configurations updated. :wrench:

- Configuration parameters updated.
- Unwanted parameters removed from AndesConfiguration
Merge pull request #215 from Asitha/inbound-event-configuration-update

Inbound event configurations updated.
Message count update logic improved

- Removed unwanted synchronisations
- Count update logic improved to avoid unexpected behaviour in multi threaded environment
- Message count update logic moved to a separate class, MessageCountFlusher