Package com.caplin.permissioning

Class PermissionPublisher

java.lang.Object
com.caplin.permissioning.PermissionPublisher
public class PermissionPublisher extends Object

  • Constructor Summary

    Constructors
    Constructor
    Description
    PermissionPublisher(com.caplin.datasource.publisher.CompatibilityPublisher activePublisher, com.caplin.datasource.publisher.BroadcastPublisher broadcastPublisher, com.caplin.permissioning.SubscriptionManager subscriptionManager, com.caplin.permissioning.RoleInternal role, Logger logger)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    activeAdd(com.caplin.datasource.Peer peer, User user, com.caplin.permissioning.PermissionStore store)
     
    void
    activeDelete(com.caplin.datasource.SubjectErrorEvent subjectErrorEvent, com.caplin.permissioning.PermissionStore store, com.caplin.permissioning.TransactionWrapper wrapper)
     
    void
    activeDiscard(com.caplin.datasource.Peer peer, String containerSubject, com.caplin.permissioning.PermissionStore store)
     
    void
    activeError(String subject)
     
    void
    activeUpdate(com.caplin.datasource.messaging.container.ContainerMessage message, User user, com.caplin.permissioning.PermissionStore store, com.caplin.permissioning.TransactionWrapper wrapper)
     
    void
    broadcast(com.caplin.datasource.messaging.Message message, com.caplin.permissioning.TransactionWrapper wrapper)
     
    void
    broadcast(com.caplin.datasource.Peer peer, com.caplin.datasource.messaging.Message message, com.caplin.permissioning.TransactionWrapper wrapper)
     
    void
    broadcast(com.caplin.datasource.Peer peer, List<? extends com.caplin.datasource.messaging.Message> messages, com.caplin.permissioning.TransactionWrapper wrapper)
     
    void
    broadcast(List<? extends com.caplin.datasource.messaging.Message> messages, com.caplin.permissioning.TransactionWrapper wrapper)
     
    void
    broadcastError(com.caplin.datasource.Peer peer, com.caplin.datasource.SubjectErrorEvent subjectErrorEvent)
     
    void
    broadcastToActivePeers(com.caplin.datasource.messaging.Message message, com.caplin.permissioning.TransactionWrapper wrapper)
     
    void
    broadcastToActivePeers(List<? extends com.caplin.datasource.messaging.Message> messages, com.caplin.permissioning.TransactionWrapper wrapper)
     
    void
    broadcastUpdate(com.caplin.datasource.messaging.permission.PermissionMessage message, com.caplin.permissioning.TransactionWrapper wrapper)
     
    void
    broadcastUpdate(com.caplin.datasource.Peer peer, com.caplin.datasource.messaging.permission.PermissionMessage message, com.caplin.permissioning.TransactionWrapper wrapper)
     
    void
    broadcastUpdate(List<? extends com.caplin.datasource.messaging.Message> messages, com.caplin.permissioning.TransactionWrapper wrapper)
     
    com.caplin.datasource.messaging.MessageFactory
    getMessageFactory()
     
    void
    sendClear(com.caplin.datasource.Peer peer)
     
    void
    sendGlobalDefaults(com.caplin.datasource.Peer peer, com.caplin.permissioning.PermissionStore store)
     
    void
    sendRules(com.caplin.datasource.Peer peer, com.caplin.permissioning.PermissionStore store)
     
    void
    sendRulesAndGlobalDefaults(com.caplin.datasource.Peer peer, com.caplin.permissioning.PermissionStore store)
     
    void
    setSerializer(com.caplin.permissioning.Serialiser serializer)
     
    void
    unlockCommit()
     
    com.caplin.datasource.messaging.record.WrapperMessage
    wrapPermissionMessages(String subject, List<com.caplin.datasource.messaging.permission.PermissionMessage> list)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • PermissionPublisher

      public PermissionPublisher(com.caplin.datasource.publisher.CompatibilityPublisher activePublisher, com.caplin.datasource.publisher.BroadcastPublisher broadcastPublisher, com.caplin.permissioning.SubscriptionManager subscriptionManager, com.caplin.permissioning.RoleInternal role, Logger logger)

  • Method Details

    • setSerializer

      public void setSerializer(com.caplin.permissioning.Serialiser serializer)

    • broadcast

      public void broadcast(com.caplin.datasource.Peer peer, com.caplin.datasource.messaging.Message message, com.caplin.permissioning.TransactionWrapper wrapper)

    • broadcast

      public void broadcast(com.caplin.datasource.Peer peer, List<? extends com.caplin.datasource.messaging.Message> messages, com.caplin.permissioning.TransactionWrapper wrapper)

    • broadcast

      public void broadcast(com.caplin.datasource.messaging.Message message, com.caplin.permissioning.TransactionWrapper wrapper)

    • broadcastToActivePeers

      public void broadcastToActivePeers(com.caplin.datasource.messaging.Message message, com.caplin.permissioning.TransactionWrapper wrapper)

    • broadcastToActivePeers

      public void broadcastToActivePeers(List<? extends com.caplin.datasource.messaging.Message> messages, com.caplin.permissioning.TransactionWrapper wrapper)

    • broadcast

      public void broadcast(List<? extends com.caplin.datasource.messaging.Message> messages, com.caplin.permissioning.TransactionWrapper wrapper)

    • broadcastError

      public void broadcastError(com.caplin.datasource.Peer peer, com.caplin.datasource.SubjectErrorEvent subjectErrorEvent)

    • broadcastUpdate

      public void broadcastUpdate(com.caplin.datasource.Peer peer, com.caplin.datasource.messaging.permission.PermissionMessage message, com.caplin.permissioning.TransactionWrapper wrapper)

    • broadcastUpdate

      public void broadcastUpdate(com.caplin.datasource.messaging.permission.PermissionMessage message, com.caplin.permissioning.TransactionWrapper wrapper)

    • broadcastUpdate

      public void broadcastUpdate(List<? extends com.caplin.datasource.messaging.Message> messages, com.caplin.permissioning.TransactionWrapper wrapper)

    • activeAdd

      public void activeAdd(com.caplin.datasource.Peer peer, User user, com.caplin.permissioning.PermissionStore store)

    • activeUpdate

      public void activeUpdate(com.caplin.datasource.messaging.container.ContainerMessage message, User user, com.caplin.permissioning.PermissionStore store, com.caplin.permissioning.TransactionWrapper wrapper)

    • activeDelete

      public void activeDelete(com.caplin.datasource.SubjectErrorEvent subjectErrorEvent, com.caplin.permissioning.PermissionStore store, com.caplin.permissioning.TransactionWrapper wrapper)

    • activeDiscard

      public void activeDiscard(com.caplin.datasource.Peer peer, String containerSubject, com.caplin.permissioning.PermissionStore store)

    • sendRulesAndGlobalDefaults

      public void sendRulesAndGlobalDefaults(com.caplin.datasource.Peer peer, com.caplin.permissioning.PermissionStore store)

    • sendClear

      public void sendClear(com.caplin.datasource.Peer peer)

    • sendRules

      public void sendRules(com.caplin.datasource.Peer peer, com.caplin.permissioning.PermissionStore store)

    • sendGlobalDefaults

      public void sendGlobalDefaults(com.caplin.datasource.Peer peer, com.caplin.permissioning.PermissionStore store)

    • activeError

      public void activeError(String subject)

    • getMessageFactory

      public com.caplin.datasource.messaging.MessageFactory getMessageFactory()

    • wrapPermissionMessages

      public com.caplin.datasource.messaging.record.WrapperMessage wrapPermissionMessages(String subject, List<com.caplin.datasource.messaging.permission.PermissionMessage> list)

    • unlockCommit

      public void unlockCommit()