[infinispan-issues] [JBoss JIRA] Commented: (ISPN-608) Make replication queue implementation pluggable

[craig bomba (JIRA)]

    [ https://jira.jboss.org/browse/ISPN-608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=12555078#action_12555078 ] 

craig bomba commented on ISPN-608:
----------------------------------

yes, I think it will work out OK to have flush return the number of items that were flushed.

I'll create a JIRA for the out-of-order issue.  

> Make replication queue implementation pluggable
> -----------------------------------------------
>
>                 Key: ISPN-608
>                 URL: https://jira.jboss.org/browse/ISPN-608
>             Project: Infinispan
>          Issue Type: Feature Request
>          Components: Core API
>    Affects Versions: 4.1.0.CR3
>            Reporter: craig bomba
>            Assignee: Manik Surtani
>            Priority: Minor
>             Fix For: 4.2.0.ALPHA1, 4.2.0.Final
>
>         Attachments: infinispan-core-repl-queue.jar
>
>
> We needed to make the ReplicationQueue listenable. We needed events for adding a command to and flushing the queue.
> org.infinispan.factories.EmptyConstructorNamedCacheFactory
> Just added ReplicationQueueNotifier.class to the @DefaultFactoryFor annotation.
> org.infinispan.notifications.replicationqueuelistener.ReplicationQueueNotifier
> Interface for the ReplicationQueue notifier.
> org.infinispan.notifications.replicationqueuelistener.ReplicationQueueNotifierImpl
> The ReplicationQueue notifier implementation. Supports events for adding and a command to and flushing the queue.
> org.infinispan.notifications.replicationqueuelistener.annotation.Flush
> org.infinispan.notifications.replicationqueuelistener.annotation.ReplicableCommandAdded
> The bare annotations to add to ReplicationQueue listeners.
> org.infinispan.notifications.replicationqueuelistener.event.Event
> The interface for the command added and flush event implementations.
> org.infinispan.notifications.replicationqueuelistener.event.FlushEvent
> org.infinispan.notifications.replicationqueuelistener.event.ReplicableCommandAddedEvent
> The event implementations.
> org.infinispan.remoting.ReplicationQueue
> Updated to implement listenable.
>   Throws the command added event AFTER it has been added to the queue. It includes the size of the queue AFTER the command has been added.
>   Throws the flush event AFTER the queue has been flushed. It includes the size of the queue to be flushed.

-- 
This message is automatically generated by JIRA.
-
If you think it was sent incorrectly contact one of the administrators: https://jira.jboss.org/secure/Administrators.jspa
-
For more information on JIRA, see: http://www.atlassian.com/software/jira