Revision 36601
Added by Nikon Gasparis about 9 years ago
| SNManagerImpl.java | ||
|---|---|---|
| 38 | 38 |
|
| 39 | 39 |
@Override |
| 40 | 40 |
public void subscribe(Subscription sub, NotificationListener listener) {
|
| 41 |
SubscriptionTask task = tasks.get(sub.getTopic()); |
|
| 42 |
|
|
| 43 |
if (task == null) {
|
|
| 44 |
logger.debug("New topic: " + sub.getTopic());
|
|
| 45 |
task = new SubscriptionTask(sub, listener); |
|
| 46 |
|
|
| 47 |
tasks.put(sub.getTopic(), task); |
|
| 48 |
|
|
| 49 |
sub.setTimeToLive(this.timeToLive); |
|
| 50 |
|
|
| 51 |
executor.execute(task); |
|
| 41 |
//TODO |
|
| 42 |
//TEMPORARY FIX FOR REJECTED SUBSCRIPTIONS. ISSUE:1288 |
|
| 43 |
if (!sub.getTopic().split("/")[2].equals("*")) {
|
|
| 44 |
SubscriptionTask task = tasks.get(sub.getTopic()); |
|
| 45 |
if (task == null) {
|
|
| 46 |
logger.debug("New topic: " + sub.getTopic());
|
|
| 47 |
task = new SubscriptionTask(sub, listener); |
|
| 48 |
|
|
| 49 |
tasks.put(sub.getTopic(), task); |
|
| 50 |
|
|
| 51 |
sub.setTimeToLive(this.timeToLive); |
|
| 52 |
|
|
| 53 |
executor.execute(task); |
|
| 54 |
} else {
|
|
| 55 |
logger.debug("Topic already exists, adding listener");
|
|
| 56 |
task.getListeners().add(listener); |
|
| 57 |
} |
|
| 52 | 58 |
} else {
|
| 53 |
logger.debug("Topic already exists, adding listener");
|
|
| 54 |
task.getListeners().add(listener); |
|
| 59 |
logger.debug("subscription for resourceType: " + sub.getTopic().split("/")[1] + " ignored due to missing identifier");
|
|
| 55 | 60 |
} |
| 56 | 61 |
} |
| 57 | 62 |
|
Also available in: Unified diff
preparing to release 1.1.1