Permalink
Browse files

Broker uses protobuf based serialization for now.

  • Loading branch information...
1 parent 85dbecd commit 6cc79b3271d88a52810de5958699dfa130ad0b29 jhartman committed Oct 14, 2011
@@ -46,7 +46,7 @@
public SenseiBroker(PartitionedNetworkClient<Integer> networkClient, ClusterClient clusterClient,
SenseiLoadBalancerFactory loadBalancerFactory) throws NorbertException
{
- super(networkClient, CoreSenseiServiceImpl.SERIALIZER);
+ super(networkClient, CoreSenseiServiceImpl.PROTO_SERIALIZER); //TODO: Switch to the java serializer after upgrade
_loadBalancerFactory = loadBalancerFactory;
clusterClient.addListener(this);
logger.info("created broker instance " + networkClient + " " + clusterClient + " " + loadBalancerFactory);
@@ -41,7 +41,7 @@
public SenseiSysBroker(PartitionedNetworkClient<Integer> networkClient, ClusterClient clusterClient,
SenseiLoadBalancerFactory loadBalancerFactory, Comparator<String> versionComparator) throws NorbertException
{
- super(networkClient, SysSenseiCoreServiceImpl.SERIALIZER);
+ super(networkClient, SysSenseiCoreServiceImpl.PROTO_SERIALIZER);
_versionComparator = versionComparator;
_loadBalancerFactory = loadBalancerFactory;
clusterClient.addListener(this);

0 comments on commit 6cc79b3

Please sign in to comment.