These are chat archives for RBMHTechnology/eventuate

30th
Jul 2016
Alexander Semenov
@Tvaroh
Jul 30 2016 07:05

@krasserm can't get events replicated with cassandra event log. I see that remoting is configured properly from the logs:

2016-07-30 07:02:37,543 [location-akka.actor.default-dispatcher-3] DEBUG akka.remote.Remoting correlationId=unknown userId=unknown Associated [akka.tcp://location@localhost:2553] <- [akka.tcp://location@localhost:2552] 2016-07-30 07:02:37,598 [location-akka.actor.default-dispatcher-18] DEBUG a.s.Serialization(akka://location) correlationId=unknown userId=unknown Using serializer[com.rbmhtechnology.eventuate.serializer.ReplicationProtocolSerializer] for message [com.rbmhtechnology.eventuate.ReplicationProtocol$GetReplicationEndpointInfoSuccess] 2016-07-30 07:02:38,136 [location-akka.actor.default-dispatcher-3] DEBUG a.s.Serialization(akka://location) correlationId=unknown userId=unknown Using serializer[com.rbmhtechnology.eventuate.serializer.ReplicationProtocolSerializer] for message [com.rbmhtechnology.eventuate.ReplicationProtocol$ReplicationReadSuccess]

But events in the Cassandra table are not replicated and event handlers are not called for events on a remote host.

I've set up replication endpoints like this:

        new ReplicationEndpoint(
          id = appServerConfiguration.serverId,
          logNames = Set(DefaultEventLog),
          logFactory = logId => CassandraEventLog.props(logId),
          connections = Set(ReplicationConnection(host, port, ReplicationConnection.DefaultRemoteSystemName))
        )

so log name and remote actor system name should match. Can't get what I'm missing...

Alexander Semenov
@Tvaroh
Jul 30 2016 07:18
nevermind, I needed to get the log actor from the endpoint like this endpoint.logs(DefaultEventLog)