@@ -87,7 +87,7 @@ private MockTransportService buildService(final Version version) {
8787
8888
8989 public void testSendMessage () throws InterruptedException {
90- serviceA .registerRequestHandler ("internal:/ test" , SimpleTestRequest ::new , ThreadPool .Names .SAME ,
90+ serviceA .registerRequestHandler ("internal:test" , SimpleTestRequest ::new , ThreadPool .Names .SAME ,
9191 (request , channel ) -> {
9292 assertEquals (request .sourceNode , "TS_A" );
9393 SimpleTestResponse response = new SimpleTestResponse ();
@@ -97,7 +97,7 @@ public void testSendMessage() throws InterruptedException {
9797 TransportActionProxy .registerProxyAction (serviceA , "internal:test" , SimpleTestResponse ::new );
9898 serviceA .connectToNode (nodeB );
9999
100- serviceB .registerRequestHandler ("internal:/ test" , SimpleTestRequest ::new , ThreadPool .Names .SAME ,
100+ serviceB .registerRequestHandler ("internal:test" , SimpleTestRequest ::new , ThreadPool .Names .SAME ,
101101 (request , channel ) -> {
102102 assertEquals (request .sourceNode , "TS_A" );
103103 SimpleTestResponse response = new SimpleTestResponse ();
@@ -106,7 +106,7 @@ public void testSendMessage() throws InterruptedException {
106106 });
107107 TransportActionProxy .registerProxyAction (serviceB , "internal:test" , SimpleTestResponse ::new );
108108 serviceB .connectToNode (nodeC );
109- serviceC .registerRequestHandler ("internal:/ test" , SimpleTestRequest ::new , ThreadPool .Names .SAME ,
109+ serviceC .registerRequestHandler ("internal:test" , SimpleTestRequest ::new , ThreadPool .Names .SAME ,
110110 (request , channel ) -> {
111111 assertEquals (request .sourceNode , "TS_A" );
112112 SimpleTestResponse response = new SimpleTestResponse ();
@@ -150,7 +150,7 @@ public String executor() {
150150 }
151151
152152 public void testException () throws InterruptedException {
153- serviceA .registerRequestHandler ("internal:/ test" , SimpleTestRequest ::new , ThreadPool .Names .SAME ,
153+ serviceA .registerRequestHandler ("internal:test" , SimpleTestRequest ::new , ThreadPool .Names .SAME ,
154154 (request , channel ) -> {
155155 assertEquals (request .sourceNode , "TS_A" );
156156 SimpleTestResponse response = new SimpleTestResponse ();
@@ -160,7 +160,7 @@ public void testException() throws InterruptedException {
160160 TransportActionProxy .registerProxyAction (serviceA , "internal:test" , SimpleTestResponse ::new );
161161 serviceA .connectToNode (nodeB );
162162
163- serviceB .registerRequestHandler ("internal:/ test" , SimpleTestRequest ::new , ThreadPool .Names .SAME ,
163+ serviceB .registerRequestHandler ("internal:test" , SimpleTestRequest ::new , ThreadPool .Names .SAME ,
164164 (request , channel ) -> {
165165 assertEquals (request .sourceNode , "TS_A" );
166166 SimpleTestResponse response = new SimpleTestResponse ();
@@ -169,7 +169,7 @@ public void testException() throws InterruptedException {
169169 });
170170 TransportActionProxy .registerProxyAction (serviceB , "internal:test" , SimpleTestResponse ::new );
171171 serviceB .connectToNode (nodeC );
172- serviceC .registerRequestHandler ("internal:/ test" , SimpleTestRequest ::new , ThreadPool .Names .SAME ,
172+ serviceC .registerRequestHandler ("internal:test" , SimpleTestRequest ::new , ThreadPool .Names .SAME ,
173173 (request , channel ) -> {
174174 throw new ElasticsearchException ("greetings from TS_C" );
175175 });
0 commit comments