|
Change Parameter Type msg : MessageAdapter to msg : Message in method public sendMessage(destNode ClusterNode, msg Message) : void in class org.apache.ignite.internal.processors.cache.distributed.replicated.GridCacheReplicatedInvalidateSelfTest.TestCommunicationSpi |
From |
To |
|
Change Parameter Type cls : Class<? extends MessageAdapter> to cls : Class<? extends Message> in method public generateAndWrite(cls Class<? extends Message>) : void in class org.apache.ignite.codegen.MessageCodeGenerator |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public writeMessage(name String, msg Message) : boolean in class org.apache.ignite.internal.direct.DirectMessageWriter |
From |
To |
|
Change Parameter Type val : MessageAdapter to val : Message in method public writeMessage(name String, val Message) : boolean in class org.apache.ignite.plugin.extensions.communication.MessageWriter |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public sendMessage(nodeId UUID, msg Message) : boolean in class org.apache.ignite.internal.util.nio.GridTcpNioCommunicationClient |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public sendMessage(node ClusterNode, msg Message) : void in class org.apache.ignite.internal.processors.cache.IgniteCacheAbstractStopBusySelfTest.TestTpcCommunicationSpi |
From |
To |
|
Change Parameter Type obj : MessageAdapter to obj : Message in method private checkAwaitMessageType(obj Message, srcNodeId UUID) : void in class org.apache.ignite.spi.communication.tcp.GridCacheDhtLockBackupSelfTest.TestCommunicationSpi |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public onMessage(nodeId UUID, msg Message, msgC IgniteRunnable) : void in class org.apache.ignite.spi.communication.GridAbstractCommunicationSelfTest.MessageListener |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method private sendMessage0(node ClusterNode, msg Message) : void in class org.apache.ignite.internal.GridJobMasterLeaveAwareSelfTest.CommunicationSpi |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public sendMessage(node ClusterNode, msg Message) : void in class org.apache.ignite.internal.GridJobMasterLeaveAwareSelfTest.CommunicationSpi |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public send(nodes Collection<? extends ClusterNode>, topic Object, msg Message, plc GridIoPolicy) : void in class org.apache.ignite.internal.managers.communication.GridIoManager |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public sendMessage(node ClusterNode, msg Message) : void in class org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridCacheAtomicInvalidPartitionHandlingSelfTest.DelayCommunicationSpi |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method package send(ses GridNioSession, msg Message) : GridNioFuture<?> in class org.apache.ignite.internal.util.nio.GridNioServer |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public sendMessage(nodeId UUID, msg Message) : boolean in class org.apache.ignite.internal.util.nio.GridTcpCommunicationClient |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public send(nodeId UUID, topic GridTopic, msg Message, plc GridIoPolicy) : void in class org.apache.ignite.internal.managers.communication.GridIoManager |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public sendOrderedMessage(node ClusterNode, topic Object, msg Message, plc GridIoPolicy, timeout long, skipOnTimeout boolean) : void in class org.apache.ignite.internal.managers.communication.GridIoManager |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public sendMessage(node ClusterNode, msg Message) : void in class org.apache.ignite.internal.processors.cache.distributed.dht.GridCacheDhtPreloadMessageCountTest.TestCommunicationSpi |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public sendMessage(node ClusterNode, msg Message) : void in class org.apache.ignite.internal.client.integration.ClientAbstractMultiNodeSelfTest.TestCommunicationSpi |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method protected notifyListener(sndId UUID, msg Message, msgC IgniteRunnable) : void in class org.apache.ignite.spi.communication.tcp.GridOrderedMessageCancelSelfTest.CommunicationSpi |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public send(node ClusterNode, topic Object, msg Message, plc GridIoPolicy) : void in class org.apache.ignite.internal.managers.communication.GridIoManager |
From |
To |
|
Change Parameter Type skipRecoveryPred : IgnitePredicate<MessageAdapter> to skipRecoveryPred : IgnitePredicate<Message> in method public skipRecoveryPredicate(skipRecoveryPred IgnitePredicate<Message>) : Builder<T> in class org.apache.ignite.internal.util.nio.GridNioServer.Builder |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public onMessage(nodeId UUID, msg Message, msgC IgniteRunnable) : void in class org.apache.ignite.spi.communication.tcp.GridTcpCommunicationSpiLanTest.MessageListener |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public send(nodeId UUID, topic Object, msg Message, plc GridIoPolicy) : void in class org.apache.ignite.internal.managers.communication.GridIoManager |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public sendMessage(nodeId UUID, msg Message) : boolean in class org.apache.ignite.internal.util.nio.GridCommunicationClient |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method protected notifyListener(sndId UUID, msg Message, msgC IgniteRunnable) : void in class org.apache.ignite.spi.communication.tcp.GridCacheDhtLockBackupSelfTest.TestCommunicationSpi |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public sendOrderedMessage(nodes Collection<? extends ClusterNode>, topic Object, msg Message, plc GridIoPolicy, timeout long, skipOnTimeout boolean) : void in class org.apache.ignite.internal.managers.communication.GridIoManager |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public sendMessage(node ClusterNode, msg Message) : void in class org.apache.ignite.internal.managers.deployment.GridDeploymentMessageCountSelfTest.MessageCountingCommunicationSpi |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method private send(node ClusterNode, topic Object, topicOrd int, msg Message, plc GridIoPolicy, ordered boolean, timeout long, skipOnTimeout boolean) : void in class org.apache.ignite.internal.managers.communication.GridIoManager |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public send(node ClusterNode, topic GridTopic, msg Message, plc GridIoPolicy) : void in class org.apache.ignite.internal.managers.communication.GridIoManager |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public sendMessage(nodeId UUID, msg Message) : boolean in class org.apache.ignite.internal.util.nio.GridShmemCommunicationClient |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public GridIoMessage(plc GridIoPolicy, topic Object, topicOrd int, msg Message, ordered boolean, timeout long, skipOnTimeout boolean) in class org.apache.ignite.internal.managers.communication.GridIoMessage |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public sendOrderedMessage(nodeId UUID, topic Object, msg Message, plc GridIoPolicy, timeout long, skipOnTimeout boolean) : void in class org.apache.ignite.internal.managers.communication.GridIoManager |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public sendSystem(ses GridNioSession, msg Message, lsnr IgniteInClosure<? super GridNioFuture<?>>) : GridNioFuture<?> in class org.apache.ignite.internal.util.nio.GridNioServer |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public sendSystem(ses GridNioSession, msg Message) : GridNioFuture<?> in class org.apache.ignite.internal.util.nio.GridNioServer |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method protected notifyListener(sndId UUID, msg Message, msgC IgniteRunnable) : void in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public onMessage(nodeId UUID, msg Message, msgC IgniteRunnable) : void in class org.apache.ignite.spi.communication.tcp.GridTcpCommunicationSpiMultithreadedSelfTest.MessageListener |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public sendMessage(node ClusterNode, msg Message) : void in class org.apache.ignite.internal.processors.cache.GridCacheReplicatedSynchronousCommitTest.TestCommunicationSpi |
From |
To |
|
Change Parameter Type skipRecoveryPred : IgnitePredicate<MessageAdapter> to skipRecoveryPred : IgnitePredicate<Message> in method private GridNioServer(addr InetAddress, port int, log IgniteLogger, selectorCnt int, gridName String, tcpNoDelay boolean, directBuf boolean, order ByteOrder, lsnr GridNioServerListener<T>, sockSndBuf int, sockRcvBuf int, sndQueueLimit int, directMode boolean, daemon boolean, metricsLsnr GridNioMetricsListener, formatter MessageFormatter, skipRecoveryPred IgnitePredicate<Message>, filters GridNioFilter...) in class org.apache.ignite.internal.util.nio.GridNioServer |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public sendMessage(node ClusterNode, msg Message) : void in class org.apache.ignite.internal.processors.cache.distributed.GridCacheAtomicTimeoutSelfTest.TestCommunicationSpi |
From |
To |
|
Change Parameter Type col : Collection<Class<? extends MessageAdapter>> to col : Collection<Class<? extends Message>> in method private processFile(file File, ldr ClassLoader, prefixLen int, col Collection<Class<? extends Message>>) : void in class org.apache.ignite.codegen.MessageCodeGenerator |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public sendMessage(node ClusterNode, msg Message) : void in class org.apache.ignite.internal.processors.cache.GridCacheAtomicMessageCountSelfTest.TestCommunicationSpi |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public onMessage(nodeId UUID, msg Message, msgC IgniteRunnable) : void in class org.apache.ignite.spi.communication.tcp.GridTcpCommunicationSpiConcurrentConnectSelfTest.MessageListener |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method private send(msg Message) : GridNioFuture<?> in class org.apache.ignite.internal.util.ipc.IpcToNioAdapter |
From |
To |
|
Change Parameter Type commMsg : MessageAdapter to commMsg : Message in method package NioOperationFuture(ses GridSelectorNioSessionImpl, op NioOperation, commMsg Message, skipRecovery boolean) in class org.apache.ignite.internal.util.nio.GridNioServer.NioOperationFuture |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public onMessage(nodeId UUID, msg Message, msgC IgniteRunnable) : void in class org.apache.ignite.spi.communication.tcp.GridTcpCommunicationSpiRecoveryAckSelfTest.TestListener |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public sendMessage(node ClusterNode, msg Message) : void in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public sendMessage(node ClusterNode, msg Message) : void in class org.apache.ignite.internal.processors.cache.IgniteTxReentryAbstractSelfTest.CountingCommunicationSpi |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method private sendWithRetries(dstNodeId UUID, msg Message) : void in class org.apache.ignite.internal.processors.streamer.IgniteStreamerImpl |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public onMessage(nodeId UUID, msg Message, msgC IgniteRunnable) : void in class org.apache.ignite.spi.communication.tcp.GridTcpCommunicationSpiRecoverySelfTest.TestListener |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public writeMessage(msg Message, writer MessageWriter) : void in class org.apache.ignite.internal.direct.DirectByteBufferStream |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public writeMessageFully(msg Message, out OutputStream, buf ByteBuffer, writer MessageWriter) : int in class org.apache.ignite.internal.util.IgniteUtils |
From |
To |
|
Change Parameter Type c : IgniteOutClosure<MessageAdapter> to c : IgniteOutClosure<Message> in method public registerCustom(type byte, c IgniteOutClosure<Message>) : void in class org.apache.ignite.internal.managers.communication.GridIoMessageFactory |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method public send(nodes Collection<? extends ClusterNode>, topic GridTopic, msg Message, plc GridIoPolicy) : void in class org.apache.ignite.internal.managers.communication.GridIoManager |
From |
To |
|
Change Parameter Type lsnr : CommunicationListener<MessageAdapter> to lsnr : CommunicationListener<Message> in method public setListener(lsnr CommunicationListener<Message>) : void in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi |
From |
To |
|
Change Parameter Type cls : Class<? extends MessageAdapter> to cls : Class<? extends Message> in method private generate(cls Class<? extends Message>) : void in class org.apache.ignite.codegen.MessageCodeGenerator |
From |
To |
|
Change Parameter Type res : MessageAdapter to res : Message in method private sendResponse(nodeId UUID, topic Object, res Message) : void in class org.apache.ignite.internal.managers.deployment.GridDeploymentCommunication |
From |
To |
|
Change Parameter Type msg : MessageAdapter to msg : Message in method private send(nodes Collection<? extends ClusterNode>, topic Object, topicOrd int, msg Message, plc GridIoPolicy, ordered boolean, timeout long, skipOnTimeout boolean) : void in class org.apache.ignite.internal.managers.communication.GridIoManager |
From |
To |
|
Change Variable Type cls : Class<? extends MessageAdapter> to cls : Class<? extends Message> in method public generateAll(write boolean) : void in class org.apache.ignite.codegen.MessageCodeGenerator |
From |
To |
|
Change Variable Type msg : MessageAdapter to msg : Message in method private resetNioServer() : GridNioServer<Message> in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi |
From |
To |
|
Change Variable Type spi : CommunicationSpi<MessageAdapter> to spi : CommunicationSpi<Message> in method protected afterTestsStopped() : void in class org.apache.ignite.spi.communication.tcp.GridTcpCommunicationSpiMultithreadedSelfTest |
From |
To |
|
Change Variable Type adapter : IpcToNioAdapter<MessageAdapter> to adapter : IpcToNioAdapter<Message> in method protected body() : void in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.ShmemWorker |
From |
To |
|
Change Variable Type msg : MessageAdapter to msg : Message in method public create(type byte) : Message in class org.apache.ignite.internal.managers.communication.GridIoMessageFactory |
From |
To |
|
Change Variable Type msg : MessageAdapter to msg : Message in method private processWrite0(key SelectionKey) : void in class org.apache.ignite.internal.util.nio.GridNioServer.DirectNioClientWorker |
From |
To |
|
Change Variable Type spi : CommunicationSpi<MessageAdapter> to spi : CommunicationSpi<Message> in method private stopSpis() : void in class org.apache.ignite.spi.communication.tcp.GridTcpCommunicationSpiRecoveryAckSelfTest |
From |
To |
|
Change Variable Type spi : CommunicationSpi<MessageAdapter> to spi : CommunicationSpi<Message> in method public testPassThroughPerformance() : void in class org.apache.ignite.spi.communication.tcp.GridTcpCommunicationSpiMultithreadedSelfTest |
From |
To |
|
Change Variable Type msg : MessageAdapter to msg : Message in method private processWriteSsl(key SelectionKey) : void in class org.apache.ignite.internal.util.nio.GridNioServer.DirectNioClientWorker |
From |
To |
|
Change Variable Type spi : CommunicationSpi<MessageAdapter> to spi : CommunicationSpi<Message> in method public testFlowSend() : void in class org.apache.ignite.spi.communication.tcp.GridTcpCommunicationSpiMultithreadedSelfTest |
From |
To |
|
Change Variable Type skipRecoveryPred : IgnitePredicate<MessageAdapter> to skipRecoveryPred : IgnitePredicate<Message> in method private resetNioServer() : GridNioServer<Message> in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi |
From |
To |
|
Change Variable Type spi : CommunicationSpi<MessageAdapter> to spi : CommunicationSpi<Message> in method protected afterTestsStopped() : void in class org.apache.ignite.spi.communication.GridAbstractCommunicationSelfTest |
From |
To |
|
Change Variable Type msg : MessageAdapter to msg : Message in method public run() : void in class org.apache.ignite.spi.communication.tcp.GridTcpCommunicationSpiMultithreadedSelfTest.testFlowSend.fut.multithreadedAsync |
From |
To |
|
Change Variable Type spi : CommunicationSpi<MessageAdapter> to spi : CommunicationSpi<Message> in method protected beforeTestsStarted() : void in class org.apache.ignite.spi.communication.tcp.GridTcpCommunicationSpiMultithreadedSelfTest |
From |
To |
|
Change Variable Type col : Collection<Class<? extends MessageAdapter>> to col : Collection<Class<? extends Message>> in method private classes() : Collection<Class<? extends Message>> in class org.apache.ignite.codegen.MessageCodeGenerator |
From |
To |
|
Change Variable Type spi : CommunicationSpi<MessageAdapter> to spi : CommunicationSpi<Message> in method private stopSpis() : void in class org.apache.ignite.spi.communication.tcp.GridTcpCommunicationSpiRecoverySelfTest |
From |
To |
|
Change Variable Type spi : CommunicationSpi<MessageAdapter> to spi : CommunicationSpi<Message> in method private startSpis(lsnr MessageListener) : void in class org.apache.ignite.spi.communication.tcp.GridTcpCommunicationSpiConcurrentConnectSelfTest |
From |
To |
|
Change Variable Type classes : Collection<Class<? extends MessageAdapter>> to classes : Collection<Class<? extends Message>> in method public generateAll(write boolean) : void in class org.apache.ignite.codegen.MessageCodeGenerator |
From |
To |
|
Change Variable Type spi : CommunicationSpi<MessageAdapter> to spi : CommunicationSpi<Message> in method public call() : Void in class org.apache.ignite.spi.communication.tcp.GridTcpCommunicationSpiConcurrentConnectSelfTest.concurrentConnect.runMultiThreaded |
From |
To |
|
Change Variable Type req : MessageAdapter to req : Message in method package sendUndeployRequest(rsrcName String, rmtNodes Collection<ClusterNode>) : void in class org.apache.ignite.internal.managers.deployment.GridDeploymentCommunication |
From |
To |
|
Change Variable Type lsnr : CommunicationListener<MessageAdapter> to lsnr : CommunicationListener<Message> in method protected notifyListener(sndId UUID, msg Message, msgC IgniteRunnable) : void in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi |
From |
To |
|
Change Variable Type c : IgniteOutClosure<MessageAdapter> to c : IgniteOutClosure<Message> in method public create(type byte) : Message in class org.apache.ignite.internal.managers.communication.GridIoMessageFactory |
From |
To |
|
Change Variable Type spi : CommunicationSpi<MessageAdapter> to spi : CommunicationSpi<Message> in method private startSpis() : void in class org.apache.ignite.spi.communication.GridAbstractCommunicationSelfTest |
From |
To |
|
Change Variable Type msg : MessageAdapter to msg : Message in method public decode(ses GridNioSession, buf ByteBuffer) : Object in class org.apache.ignite.internal.util.nio.GridDirectParser |
From |
To |
|
Change Variable Type msg0 : MessageAdapter to msg0 : Message in method public readMessage() : T in class org.apache.ignite.internal.direct.DirectByteBufferStream |
From |
To |
|
Change Variable Type entry : Entry<UUID,CommunicationSpi<MessageAdapter>> to entry : Entry<UUID,CommunicationSpi<Message>> in method public testSendToManyNodes() : void in class org.apache.ignite.spi.communication.GridAbstractCommunicationSelfTest |
From |
To |
|
Change Variable Type commSpi : CommunicationSpi<MessageAdapter> to commSpi : CommunicationSpi<Message> in method public testSendToManyNodes() : void in class org.apache.ignite.spi.communication.GridAbstractCommunicationSelfTest |
From |
To |
|
Change Variable Type ioMsg : MessageAdapter to ioMsg : Message in method public sendUserMessage(nodes Collection<? extends ClusterNode>, msg Object, topic Object, ordered boolean, timeout long) : void in class org.apache.ignite.internal.managers.communication.GridIoManager |
From |
To |
|
Change Variable Type spi : CommunicationSpi<MessageAdapter> to spi : CommunicationSpi<Message> in method private stopSpis() : void in class org.apache.ignite.spi.communication.tcp.GridTcpCommunicationSpiConcurrentConnectSelfTest |
From |
To |
|
Change Variable Type entry : Entry<UUID,CommunicationSpi<MessageAdapter>> to entry : Entry<UUID,CommunicationSpi<Message>> in method public testSendToOneNode() : void in class org.apache.ignite.spi.communication.GridAbstractCommunicationSelfTest |
From |
To |
|
Change Variable Type msg : MessageAdapter to msg : Message in method protected getConfiguration(gridName String) : IgniteConfiguration in class org.apache.ignite.internal.processors.cache.distributed.IgniteTxOriginatingNodeFailureAbstractSelfTest |
From |
To |