Package com.caplin.permissioning
Class PermissionPublisher
java.lang.Object
com.caplin.permissioning.PermissionPublisher
-
Constructor Summary
ConstructorsConstructorDescriptionPermissionPublisher
(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 TypeMethodDescriptionvoid
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
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
com.caplin.datasource.messaging.record.WrapperMessage
wrapPermissionMessages
(String subject, List<com.caplin.datasource.messaging.permission.PermissionMessage> list)
-
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
-
getMessageFactory
public com.caplin.datasource.messaging.MessageFactory getMessageFactory() -
wrapPermissionMessages
-
unlockCommit
public void unlockCommit()
-