Changeset 4161
- Timestamp:
- 2010-07-20 09:23:08 (3 years ago)
- Location:
- trunk/rowlog/api/src/main/java/org/lilycms/rowlog/api
- Files:
-
- 2 edited
-
RowLog.java (modified) (1 diff)
-
RowLogProcessor.java (modified) (1 diff)
Legend:
- Unmodified
- Added
- Removed
-
trunk/rowlog/api/src/main/java/org/lilycms/rowlog/api/RowLog.java
r4160 r4161 167 167 List<RowLogMessageConsumer> getConsumers(); 168 168 169 /** 170 * This method allows a {@link RowLogProcessor} to be set on the {@link RowLog}. 171 * The RowLog can then inform the RowLogProcessor when a {@link RowLogMessageConsumer} is registered or unregistered. 172 * This will have to be changed once the Lily distributed node behaviour is implemented. See issue #52. 173 * @param rowLogProcessor 174 */ 169 175 void setProcessor(RowLogProcessor rowLogProcessor); 170 176 } -
trunk/rowlog/api/src/main/java/org/lilycms/rowlog/api/RowLogProcessor.java
r4160 r4161 40 40 boolean isRunning(int consumerId); 41 41 42 /** 43 * Notifies the processor that a new {@link RowLogMessageConsumer} has been registered. 44 * The processor will start processing messages for this consumer. 45 */ 42 46 void consumerRegistered(RowLogMessageConsumer consumer); 43 47 48 /** 49 * Notifies the processor that a {@link RowLogMessageConsumer} has been unregistered. 50 * The processor will stop processing messages for this consumer. 51 */ 44 52 void consumerUnregistered(RowLogMessageConsumer consumer); 45 53 }
Note: See TracChangeset
for help on using the changeset viewer.