HazelCast with Mule

[yadav...@gmail.com]

HI Folks,
I am trying to configure Hazelcast with mule. I gets the following error.
+ Mule is up and kicking (every 5000ms)                    +
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
INFO  2014-10-08 08:27:00,849 [[eventservice].connector.file.mule.default.receiver.01] org.mule.transport.file.FileMessageReceiver: Lock obtained on file: /home/sushil/Desktop/sw/input/PriceEvents.txt
WARN  2014-10-08 08:27:00,944 [[eventservice].eventserviceFlow1.stage1.02] org.mule.transport.file.FileMessageReceiver: Failure trying to remove file '/home/sushil/Desktop/sw/input/PriceEvents.txt' from list of files under processing
INFO  2014-10-08 08:27:00,987 [[eventservice].eventserviceFlow1.stage1.02] org.mule.api.processor.LoggerMessageProcessor: {priceevents={priceEvent={EventId=100010, Domain=NEW YORK CITY, Status=NEW, ReportedBy=Anupam, TimeStamp=21-03-2014T12:00:00, NewStatus=persisted, Message=No Message, Territory=India, Zone=North Zone, Region=NCR, Area=Gurgaon, POS=RK Sons, ProductCategory=Cement, ProductType=50 Kg Bag, ProductId=50K, QtyRange=Any, UOM=Nos, BrandId=KJSC, BrandName=KJS Cements, Price=265, Currency=INR}}, Secondpriceevents={priceEvent={EventId=100010, Domain=NEW YORK CITY, Status=NEW, ReportedBy=Anupam, TimeStamp=21-03-2014T12:00:00, NewStatus=persisted, Message=No Message, Territory=India, Zone=North Zone, Region=NCR, Area=Gurgaon, POS=RK Sons, ProductCategory=Cement, ProductType=50 Kg Bag, ProductId=50K, QtyRange=Any, UOM=Nos, BrandId=KJSC, BrandName=KJS Cements, Price=265, Currency=INR}}}
INFO  2014-10-08 08:27:01,001 [[eventservice].eventserviceFlow1.stage1.02] org.mule.api.processor.LoggerMessageProcessor: {priceEvent={EventId=100010, Domain=NEW YORK CITY, Status=NEW, ReportedBy=Anupam, TimeStamp=21-03-2014T12:00:00, NewStatus=persisted, Message=No Message, Territory=India, Zone=North Zone, Region=NCR, Area=Gurgaon, POS=RK Sons, ProductCategory=Cement, ProductType=50 Kg Bag, ProductId=50K, QtyRange=Any, UOM=Nos, BrandId=KJSC, BrandName=KJS Cements, Price=265, Currency=INR}}
INFO  2014-10-08 08:27:01,012 [[eventservice].eventserviceFlow1.stage1.02] org.mule.api.processor.LoggerMessageProcessor: {EventId=100010, Domain=NEW YORK CITY, Status=NEW, ReportedBy=Anupam, TimeStamp=21-03-2014T12:00:00, NewStatus=persisted, Message=No Message, Territory=India, Zone=North Zone, Region=NCR, Area=Gurgaon, POS=RK Sons, ProductCategory=Cement, ProductType=50 Kg Bag, ProductId=50K, QtyRange=Any, UOM=Nos, BrandId=KJSC, BrandName=KJS Cements, Price=265, Currency=INR}
INFO  2014-10-08 08:27:01,039 [[eventservice].eventserviceFlow1.stage1.02] org.mule.api.processor.LoggerMessageProcessor: {EventId=100010, Domain=NEW YORK CITY, Status=NEW, ReportedBy=Anupam, TimeStamp=21-03-2014T12:00:00, NewStatus=persisted, Message=No Message, Territory=India, Zone=North Zone, Region=NCR, Area=Gurgaon, POS=RK Sons, ProductCategory=Cement, ProductType=50 Kg Bag, ProductId=50K, QtyRange=Any, UOM=Nos, BrandId=KJSC, BrandName=KJS Cements, Price=265, Currency=INR}_CURRENTPROCESSED
INFO  2014-10-08 08:27:01,049 [[eventservice].eventserviceFlow1.stage1.02] org.mule.api.processor.LoggerMessageProcessor: {priceevents={priceEvent={EventId=100010, Domain=NEW YORK CITY, Status=NEW, ReportedBy=Anupam, TimeStamp=21-03-2014T12:00:00, NewStatus=persisted, Message=No Message, Territory=India, Zone=North Zone, Region=NCR, Area=Gurgaon, POS=RK Sons, ProductCategory=Cement, ProductType=50 Kg Bag, ProductId=50K, QtyRange=Any, UOM=Nos, BrandId=KJSC, BrandName=KJS Cements, Price=265, Currency=INR}}, Secondpriceevents={priceEvent={EventId=100010, Domain=NEW YORK CITY, Status=NEW, ReportedBy=Anupam, TimeStamp=21-03-2014T12:00:00, NewStatus=persisted, Message=No Message, Territory=India, Zone=North Zone, Region=NCR, Area=Gurgaon, POS=RK Sons, ProductCategory=Cement, ProductType=50 Kg Bag, ProductId=50K, QtyRange=Any, UOM=Nos, BrandId=KJSC, BrandName=KJS Cements, Price=265, Currency=INR}}}
INFO  2014-10-08 08:27:01,050 [[eventservice].eventserviceFlow1.stage1.02] org.mule.api.processor.LoggerMessageProcessor: {priceEvent={EventId=100010, Domain=NEW YORK CITY, Status=NEW, ReportedBy=Anupam, TimeStamp=21-03-2014T12:00:00, NewStatus=persisted, Message=No Message, Territory=India, Zone=North Zone, Region=NCR, Area=Gurgaon, POS=RK Sons, ProductCategory=Cement, ProductType=50 Kg Bag, ProductId=50K, QtyRange=Any, UOM=Nos, BrandId=KJSC, BrandName=KJS Cements, Price=265, Currency=INR}}
INFO  2014-10-08 08:27:01,053 [[eventservice].eventserviceFlow1.stage1.02] org.mule.api.processor.LoggerMessageProcessor: NEW YORK CITY
INFO  2014-10-08 08:27:01,056 [[eventservice].eventserviceFlow1.stage1.02] org.mule.api.processor.LoggerMessageProcessor: NEW YORK CITY_100010
Oct 08, 2014 8:27:01 AM com.hazelcast.core.LifecycleService
INFO: HazelcastClient[hz.client_0_dev] is STARTING
Oct 08, 2014 8:27:01 AM com.hazelcast.core.LifecycleService
INFO: HazelcastClient[hz.client_0_dev] is STARTED
Oct 08, 2014 8:27:04 AM com.hazelcast.client.spi.ClientClusterService
WARNING: Unable to get alive cluster connection, try in 0 ms later, attempt 1 of 2.
Oct 08, 2014 8:27:07 AM com.hazelcast.client.spi.ClientClusterService
WARNING: Unable to get alive cluster connection, try in 0 ms later, attempt 2 of 2.
Oct 08, 2014 8:27:10 AM com.hazelcast.client.spi.ClientClusterService
SEVERE: Error while connecting to cluster!
java.lang.IllegalStateException: Unable to connect to any address in the config!
    at com.hazelcast.client.spi.impl.ClientClusterServiceImpl.connectToOne(ClientClusterServiceImpl.java:564)
    at com.hazelcast.client.spi.impl.ClientClusterServiceImpl.access$900(ClientClusterServiceImpl.java:59)
    at com.hazelcast.client.spi.impl.ClientClusterServiceImpl$ClusterListenerThread.pickConnection(ClientClusterServiceImpl.java:420)
    at com.hazelcast.client.spi.impl.ClientClusterServiceImpl$ClusterListenerThread.run(ClientClusterServiceImpl.java:384)
Caused by: java.net.SocketTimeoutException: connect timed out
    at java.net.PlainSocketImpl.socketConnect(Native Method)
    at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339)
    at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200)
    at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:182)
    at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
    at java.net.Socket.connect(Socket.java:579)
    at com.hazelcast.client.connection.ConnectionImpl.<init>(ConnectionImpl.java:79)
    at com.hazelcast.client.connection.SmartClientConnectionManager.newConnection(SmartClientConnectionManager.java:100)
    at com.hazelcast.client.spi.impl.ClientClusterServiceImpl.connectToOne(ClientClusterServiceImpl.java:533)
    ... 3 more

Oct 08, 2014 8:27:10 AM com.hazelcast.core.LifecycleService
INFO: HazelcastClient[hz.client_0_dev] is SHUTTING_DOWN
Oct 08, 2014 8:27:10 AM com.hazelcast.core.LifecycleService
INFO: HazelcastClient[hz.client_0_dev] is SHUTDOWN
ERROR 2014-10-08 08:27:10,379 [[eventservice].eventserviceFlow1.stage1.02] org.mule.exception.DefaultMessagingExceptionStrategy:
********************************************************************************
Message               : Failed to invoke searchCache. Message payload is of type: LinkedHashMap
Code                  : MULE_ERROR-29999
--------------------------------------------------------------------------------
Exception stack is:
1. Cannot get initial partitions! (java.lang.IllegalStateException)
  com.hazelcast.client.spi.impl.ClientPartitionServiceImpl:100 (null)
2. Failed to invoke searchCache. Message payload is of type: LinkedHashMap (org.mule.api.MessagingException)
  org.hazel.cast.processors.SearchCacheMessageProcessor:128 (http://www.mulesoft.org/docs/site/current3/apidocs/org/mule/api/MessagingException.html)
--------------------------------------------------------------------------------
Root Exception stack trace:
java.lang.IllegalStateException: Cannot get initial partitions!
    at com.hazelcast.client.spi.impl.ClientPartitionServiceImpl.getInitialPartitions(ClientPartitionServiceImpl.java:100)
    at com.hazelcast.client.spi.impl.ClientPartitionServiceImpl.start(ClientPartitionServiceImpl.java:60)
    at com.hazelcast.client.HazelcastClient.start(HazelcastClient.java:188)
    + 3 more (set debug level logging or '-Dmule.verbose.exceptions=true' for everything)
********************************************************************************

[Noctarius]

Hi Yadav,

Have you asked that question at the Mule forums / support? I don’t think that anybody of us exactly knows how Hazelcast is configured inside of Mule.

Chris

--
You received this message because you are subscribed to the Google Groups "Hazelcast" group.
To unsubscribe from this group and stop receiving emails from it, send an email to hazelcast+...@googlegroups.com.
To post to this group, send email to haze...@googlegroups.com.
Visit this group at http://groups.google.com/group/hazelcast.
To view this discussion on the web visit https://groups.google.com/d/msgid/hazelcast/e8c4d30e-ff20-4208-9dc9-aabafe1d680e%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.