()
| 105 | |
| 106 | // Typed accessors for internal use |
| 107 | @SuppressWarnings("unchecked") |
| 108 | private ConcurrentHashMap<String, Future> futuresMap() { return (ConcurrentHashMap<String, Future>) futures; } |
| 109 | @SuppressWarnings("unchecked") |
| 110 | public ConcurrentHashMap<String, Object> subscriptionsMap() { return (ConcurrentHashMap<String, Object>) subscriptions; } |
| 111 | @SuppressWarnings("unchecked") |