@@ -924,11 +924,13 @@ The configuration of enabling broadcasting is done on the client level, by setti
924
924
925
925
<os-remoting : executor-proxy id =" dataProcessor" giga-space =" gigaSpace"
926
926
interface =" org.openspaces.example.data.common.IDataProcessor" broadcast =" true" >
927
+ <os-remoting : result-reducer ref =" remoteResultReducer" />
927
928
</os-remoting : executor-proxy >
928
929
929
930
<bean id =" dataRemoting" class =" DataRemoting" >
930
931
<property name =" dataProcessor" ref =" dataProcessor" />
931
932
</bean >
933
+ <bean id =" remoteResultReducer" class =" MyRemoteResultReducer" />
932
934
```
933
935
934
936
{{% /tab %}}
@@ -948,11 +950,13 @@ The configuration of enabling broadcasting is done on the client level, by setti
948
950
<property name =" gigaSpace" ref =" gigaSpace" />
949
951
<property name =" serviceInterface" value =" org.openspaces.example.data.common.IDataProcessor" />
950
952
<property name =" broadcast" value =" true" />
953
+ <property name =" remoteResultReducer" ref =" remoteResultReducer" />
951
954
</bean >
952
955
953
956
<bean id =" dataRemoting" class =" DataRemoting" >
954
957
<property name =" dataProcessor" ref =" dataProcessor" />
955
958
</bean >
959
+ <bean id =" remoteResultReducer" class =" MyRemoteResultReducer" />
956
960
```
957
961
958
962
{{% /tab %}}
@@ -964,8 +968,11 @@ SpaceProxyConfigurer configurer = new SpaceProxyConfigurer("space");
964
968
965
969
GigaSpace gigaSpace = new GigaSpaceConfigurer (configurer). gigaSpace();
966
970
971
+ MyRemoteResultReducer myRemoteResultReducer = new MyRemoteResultReducer ();
972
+
967
973
IDataProcessor dataProcessor = new ExecutorRemotingProxyConfigurer<IDataProcessor > (gigaSpace, IDataProcessor . class)
968
974
.broadcast(true )
975
+ .remoteResultReducer(myRemoteResultReducer)
969
976
.proxy();
970
977
971
978
DataRemoting dataRemoting = new DataRemoting ();
0 commit comments