Mentions légales du service

Skip to content
Snippets Groups Projects
Commit 928d54a5 authored by Gabriel Landais's avatar Gabriel Landais
Browse files

Better message filtering

git-svn-id: https://scm.gforge.inria.fr/authscm/ycadoret/svn/gazelle/Maven/gazelle-proxy/trunk@26636 356b4b1a-1d2b-0410-8bf1-ffa24008f01e
parent c625fdfd
No related branches found
No related tags found
No related merge requests found
...@@ -54,14 +54,14 @@ public class ProxyForTM implements IProxyForTM { ...@@ -54,14 +54,14 @@ public class ProxyForTM implements IProxyForTM {
List<Integer> ids = step.getReceiverIds(); List<Integer> ids = step.getReceiverIds();
List<Configuration> stepConfigurations = new ArrayList<Configuration>(); List<Configuration> stepConfigurations = new ArrayList<Configuration>();
if (ids != null) { if (ids != null) {
stepConfigurations = getStepConfigurations(configurations, ids); stepConfigurations = getStepConfigurations(configurations, ids, true);
} }
step.setReceivers(stepConfigurations); step.setReceivers(stepConfigurations);
ids = step.getSenderIds(); ids = step.getSenderIds();
stepConfigurations = new ArrayList<Configuration>(); stepConfigurations = new ArrayList<Configuration>();
if (ids != null) { if (ids != null) {
stepConfigurations = getStepConfigurations(configurations, ids); stepConfigurations = getStepConfigurations(configurations, ids, false);
} }
step.setSenders(stepConfigurations); step.setSenders(stepConfigurations);
} }
...@@ -77,12 +77,19 @@ public class ProxyForTM implements IProxyForTM { ...@@ -77,12 +77,19 @@ public class ProxyForTM implements IProxyForTM {
} }
private List<Configuration> getStepConfigurations(List<Configuration> configurations, List<Integer> ids) { private List<Configuration> getStepConfigurations(List<Configuration> configurations, List<Integer> ids,
boolean receiver) {
List<Configuration> stepConfigurations = new ArrayList<Configuration>(); List<Configuration> stepConfigurations = new ArrayList<Configuration>();
for (Integer id : ids) { for (Integer id : ids) {
Configuration stepConfiguration = getConfigurationByTmId(id, configurations); Configuration stepConfiguration = getConfigurationByTmId(id, configurations);
if (stepConfiguration != null && stepConfiguration.getProxyPort() > 0) { if (stepConfiguration != null) {
stepConfigurations.add(stepConfiguration); if (receiver) {
if (stepConfiguration.getProxyPort() > 0) {
stepConfigurations.add(stepConfiguration);
}
} else {
stepConfigurations.add(stepConfiguration);
}
} }
} }
return stepConfigurations; return stepConfigurations;
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment