[jira] [Closed] (GEODE-387) GatewayReceivers configured using cache xml should be started after the regions are created

["Anthony Baker (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/GEODE-387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Anthony Baker closed GEODE-387.
-------------------------------

> GatewayReceivers configured using cache xml should be started after the regions are created
> -------------------------------------------------------------------------------------------
>
>                 Key: GEODE-387
>                 URL: https://issues.apache.org/jira/browse/GEODE-387
>             Project: Geode
>          Issue Type: Bug
>          Components: wan
>            Reporter: Barry Oglesby
>            Assignee: Barry Oglesby
>            Priority: Major
>
> Currently, {{GatewayReceivers}} configured using cache xml are started before the {{Regions}} in that xml. This can cause data loss since a remote {{GatewaySender}} could connect to that {{GatewayReceiver}} and send batches before the {{Regions}} are created.
> First, the {{GatewayReceiver}} is started:
> {noformat}
> [info 2015/04/29 16:30:38.644 PDT host1 <main> tid=0x1] The GatewayReceiver started on port : 1,575
> {noformat}
> Then, events start being received and dropped:
> {noformat}
> [warning 2015/04/29 16:30:38.978 PDT host1 <ServerConnection on port 1575 Thread 1> tid=0x7b] Server connection from [identity(xx.x.xx.xx(host1:6372)<v2>:27373,connection=1; port=36493]: Wrote batch exception: 
> com.gemstone.gemfire.internal.cache.wan.BatchException70: Exception occurred while processing a batch on the receiver running on DistributedSystem with Id: 2, DistributedMember on which the receiver is running: xx.x.xx.xxx(host1:25784)<v6>:3298
> 	at com.gemstone.gemfire.internal.cache.tier.sockets.command.GatewayReceiverCommand.cmdExecute(GatewayReceiverCommand.java:648)
> 	at com.gemstone.gemfire.internal.cache.tier.sockets.BaseCommand.execute(BaseCommand.java:182)
> 	at com.gemstone.gemfire.internal.cache.tier.sockets.ServerConnection.doNormalMsg(ServerConnection.java:789)
> 	at com.gemstone.gemfire.internal.cache.tier.sockets.ServerConnection.doOneMessage(ServerConnection.java:920)
> 	at com.gemstone.gemfire.internal.cache.tier.sockets.ServerConnection.run(ServerConnection.java:1165)
> 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
> 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
> 	at com.gemstone.gemfire.internal.cache.tier.sockets.AcceptorImpl$1$1.run(AcceptorImpl.java:577)
> 	at java.lang.Thread.run(Thread.java:724)
> Caused by: com.gemstone.gemfire.cache.RegionDestroyedException: Region /trade was not found during batch create request 0
> 	at com.gemstone.gemfire.internal.cache.tier.sockets.command.GatewayReceiverCommand.cmdExecute(GatewayReceiverCommand.java:288)
> 	... 8 more
> {noformat}
> Finally, the region is created:
> {noformat}
> [info 2015/04/29 16:30:39.203 PDT host1 <main> tid=0x1] Partitioned Region /trade is born with prId=21 ident:#trade
> {noformat}
> In {{CacheCreation.create}}, the {{GatewayReceiver}} is created and started before the regions are initialized. For comparison, the {{GatewayHub}} (which is the predecessor to the {{GatewayReceiver}}) is started after the regions are created. This is the way it should be.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)