File tree Expand file tree Collapse file tree
plugins/event-bus/inmemory/src/org/apache/cloudstack/mom/inmemory
utils/src/com/cloud/utils/backoff/impl Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2626import javax .ejb .Local ;
2727import javax .naming .ConfigurationException ;
2828
29+ import org .apache .log4j .Logger ;
30+
2931import org .apache .cloudstack .framework .events .Event ;
3032import org .apache .cloudstack .framework .events .EventBus ;
3133import org .apache .cloudstack .framework .events .EventBusException ;
3234import org .apache .cloudstack .framework .events .EventSubscriber ;
3335import org .apache .cloudstack .framework .events .EventTopic ;
34- import org .apache .log4j .Logger ;
3536
3637import com .cloud .utils .Pair ;
3738import com .cloud .utils .component .ManagerBase ;
@@ -41,7 +42,7 @@ public class InMemoryEventBus extends ManagerBase implements EventBus {
4142
4243 private static final Logger s_logger = Logger .getLogger (InMemoryEventBus .class );
4344
44- private final static ConcurrentHashMap <UUID , Pair <EventTopic , EventSubscriber >> subscribers ;
45+ private final static Map <UUID , Pair <EventTopic , EventSubscriber >> subscribers ;
4546
4647 static {
4748 subscribers = new ConcurrentHashMap <UUID , Pair <EventTopic , EventSubscriber >>();
Original file line number Diff line number Diff line change 4545@ Local (value = {BackoffAlgorithm .class })
4646public class ConstantTimeBackoff extends AdapterBase implements BackoffAlgorithm , ConstantTimeBackoffMBean {
4747 long _time ;
48- private final ConcurrentHashMap <String , Thread > _asleep = new ConcurrentHashMap <String , Thread >();
48+ private final Map <String , Thread > _asleep = new ConcurrentHashMap <String , Thread >();
4949 private final static Log LOG = LogFactory .getLog (ConstantTimeBackoff .class );
5050
5151 @ Override
You can’t perform that action at this time.
0 commit comments