Skip to content

Instantly share code, notes, and snippets.

@dnno

dnno/DisabledTopologyStateTransferTransportFactory.java

Created January 21, 2018 17:25
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save dnno/094ff07a66b0a07dded38c3f142caf30 to your computer and use it in GitHub Desktop.
Save dnno/094ff07a66b0a07dded38c3f142caf30 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
DisabledTopologyStateTransferTransportFactory.java
public class DisabledTopologyStateTransferTransportFactory extends TcpTransportFactory {
private static final Logger LOG = LoggerFactory.getLogger(DisabledTopologyStateTransferTransportFactory.class);
@Override
public void updateServers(final Collection<SocketAddress> newServers, final byte[] cacheName, final boolean quiet) {
LOG.info("Receiving new Servers: {}. Ignoring...", newServers);
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment