[hornetq-commits] JBoss hornetq SVN: r9707 - trunk/src/main/org/hornetq/core/postoffice/impl.
do-not-reply at jboss.org
do-not-reply at jboss.org
Tue Sep 21 09:38:27 EDT 2010
Author: timfox
Date: 2010-09-21 09:38:26 -0400 (Tue, 21 Sep 2010)
New Revision: 9707
Modified:
trunk/src/main/org/hornetq/core/postoffice/impl/PostOfficeImpl.java
Log:
https://jira.jboss.org/browse/HORNETQ-521
Modified: trunk/src/main/org/hornetq/core/postoffice/impl/PostOfficeImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/postoffice/impl/PostOfficeImpl.java 2010-09-21 09:52:36 UTC (rev 9706)
+++ trunk/src/main/org/hornetq/core/postoffice/impl/PostOfficeImpl.java 2010-09-21 13:38:26 UTC (rev 9707)
@@ -483,24 +483,24 @@
if (binding.getType() == BindingType.LOCAL_QUEUE)
{
managementService.unregisterQueue(uniqueName, binding.getAddress());
+
+ TypedProperties props = new TypedProperties();
+
+ props.putSimpleStringProperty(ManagementHelper.HDR_ADDRESS, binding.getAddress());
+
+ props.putSimpleStringProperty(ManagementHelper.HDR_CLUSTER_NAME, binding.getClusterName());
+
+ props.putSimpleStringProperty(ManagementHelper.HDR_ROUTING_NAME, binding.getRoutingName());
+
+ props.putIntProperty(ManagementHelper.HDR_DISTANCE, binding.getDistance());
+
+ managementService.sendNotification(new Notification(null, NotificationType.BINDING_REMOVED, props));
}
else if (binding.getType() == BindingType.DIVERT)
{
managementService.unregisterDivert(uniqueName);
}
- TypedProperties props = new TypedProperties();
-
- props.putSimpleStringProperty(ManagementHelper.HDR_ADDRESS, binding.getAddress());
-
- props.putSimpleStringProperty(ManagementHelper.HDR_CLUSTER_NAME, binding.getClusterName());
-
- props.putSimpleStringProperty(ManagementHelper.HDR_ROUTING_NAME, binding.getRoutingName());
-
- props.putIntProperty(ManagementHelper.HDR_DISTANCE, binding.getDistance());
-
- managementService.sendNotification(new Notification(null, NotificationType.BINDING_REMOVED, props));
-
binding.close();
return binding;
More information about the hornetq-commits
mailing list