mirror of
https://github.com/apache/activemq.git
synced 2025-02-26 20:15:19 +00:00
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@392624 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
973147afb0
commit
2373eb2d22
@ -186,7 +186,7 @@ public class ManagedRegionBroker extends RegionBroker{
|
|||||||
}
|
}
|
||||||
|
|
||||||
public void unregisterSubscription(Subscription sub){
|
public void unregisterSubscription(Subscription sub){
|
||||||
ObjectName name=(ObjectName) subscriptionMap.get(sub);
|
ObjectName name=(ObjectName) subscriptionMap.remove(sub);
|
||||||
if(name!=null){
|
if(name!=null){
|
||||||
try{
|
try{
|
||||||
unregisterSubscription(name);
|
unregisterSubscription(name);
|
||||||
@ -331,7 +331,7 @@ public class ManagedRegionBroker extends RegionBroker{
|
|||||||
try{
|
try{
|
||||||
c[i]=OpenTypeSupport.convert((Message) messages.get(i));
|
c[i]=OpenTypeSupport.convert((Message) messages.get(i));
|
||||||
}catch(Throwable e){
|
}catch(Throwable e){
|
||||||
e.printStackTrace();
|
log.error("failed to browse : " + view,e);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return c;
|
return c;
|
||||||
|
Loading…
x
Reference in New Issue
Block a user