|
Change Return Type List<QueueMessage> to rx.Observable<QueueMessage> in method public getMessages(limit int, transactionTimeout int, waitTime int, klass Class) : rx.Observable<QueueMessage> in class org.apache.usergrid.persistence.queue.impl.SQSQueueManagerImpl |
From |
To |
|
Change Return Type List<QueueMessage> to Observable<QueueMessage> in method public getMessages(limit int, transactionTimeout int, waitTime int, klass Class) : Observable<QueueMessage> in class org.apache.usergrid.services.queues.ImportQueueManager |
From |
To |
|
Change Return Type List<QueueMessage> to rx.Observable<QueueMessage> in method public getMessages(limit int, transactionTimeout int, waitTime int, klass Class) : rx.Observable<QueueMessage> in class org.apache.usergrid.persistence.queue.impl.SNSQueueManagerImpl |
From |
To |
|
Change Return Type List<QueueMessage> to Observable<QueueMessage> in method public getMessages(limit int, transactionTimeout int, waitTime int, klass Class) : Observable<QueueMessage> in class org.apache.usergrid.persistence.queue.DefaultQueueManager |
From |
To |
|
Change Return Type List<QueueMessage> to Observable<QueueMessage> in method private take() : Observable<QueueMessage> in class org.apache.usergrid.corepersistence.asyncevents.AmazonAsyncEventService |
From |
To |
|
Change Return Type List<QueueMessage> to Observable<QueueMessage> in method public getMessages(limit int, transactionTimeout int, waitTime int, klass Class) : Observable<QueueMessage> in class org.apache.usergrid.persistence.queue.QueueManager |
From |
To |