Examples of addToMessage()

Examples of org.fudgemsg.mapping.FudgeSerializer.addToMessage()

38
39
40
41
42
43
44
45
46
47
48
  @Override
  public void addBlacklistRule(final FunctionBlacklistRule rule, final int timeToLive) {
    final FudgeSerializer fsc = new FudgeSerializer(getProvider().getFudgeContext());
    final MutableFudgeMsg msg = fsc.newMessage();
    msg.add(DataManageableFunctionBlacklistResource.TTL_FIELD, null, FudgeWireType.LONG, timeToLive);
    fsc.addToMessage(msg, DataManageableFunctionBlacklistResource.RULE_FIELD, null, rule);
    getProvider().add(getName(), msg);
  }

  @Override
  public void addBlacklistRules(final Collection<FunctionBlacklistRule> rules) {
View Full Code Here

Examples of org.fudgemsg.mapping.FudgeSerializer.addToMessage()

47
48
49
50
51
52
53
54
55
56
57
  @Override
  public void addBlacklistRules(final Collection<FunctionBlacklistRule> rules) {
    final FudgeSerializer fsc = new FudgeSerializer(getProvider().getFudgeContext());
    final MutableFudgeMsg msg = fsc.newMessage();
    for (FunctionBlacklistRule rule : rules) {
      fsc.addToMessage(msg, DataManageableFunctionBlacklistResource.RULE_FIELD, null, rule);
    }
    getProvider().add(getName(), msg);
  }

  @Override
View Full Code Here

Examples of org.fudgemsg.mapping.FudgeSerializer.addToMessage()

58
59
60
61
62
63
64
65
66
67
68
  public void addBlacklistRules(final Collection<FunctionBlacklistRule> rules, final int timeToLive) {
    final FudgeSerializer fsc = new FudgeSerializer(getProvider().getFudgeContext());
    final MutableFudgeMsg msg = fsc.newMessage();
    msg.add(DataManageableFunctionBlacklistResource.TTL_FIELD, null, FudgeWireType.LONG, timeToLive);
    for (FunctionBlacklistRule rule : rules) {
      fsc.addToMessage(msg, DataManageableFunctionBlacklistResource.RULE_FIELD, null, rule);
    }
    getProvider().add(getName(), msg);
  }

  @Override
View Full Code Here

Examples of org.fudgemsg.mapping.FudgeSerializer.addToMessage()

67
68
69
70
71
72
73
74
75
76
77
  @Override
  public void removeBlacklistRule(final FunctionBlacklistRule rule) {
    final FudgeSerializer fsc = new FudgeSerializer(getProvider().getFudgeContext());
    final MutableFudgeMsg msg = fsc.newMessage();
    fsc.addToMessage(msg, DataManageableFunctionBlacklistResource.RULE_FIELD, null, rule);
    getProvider().remove(getName(), msg);
  }

  @Override
  public void removeBlacklistRules(final Collection<FunctionBlacklistRule> rules) {
View Full Code Here

Examples of org.fudgemsg.mapping.FudgeSerializer.addToMessage()

76
77
78
79
80
81
82
83
84
85
86
  @Override
  public void removeBlacklistRules(final Collection<FunctionBlacklistRule> rules) {
    final FudgeSerializer fsc = new FudgeSerializer(getProvider().getFudgeContext());
    final MutableFudgeMsg msg = fsc.newMessage();
    for (FunctionBlacklistRule rule : rules) {
      fsc.addToMessage(msg, DataManageableFunctionBlacklistResource.RULE_FIELD, null, rule);
    }
    getProvider().remove(getName(), msg);
  }

}
View Full Code Here

Examples of org.fudgemsg.mapping.FudgeSerializer.addToMessage()

94
95
96
97
98
99
100
101
102
103
104
    final MutableFudgeMsg info = fsc.newMessage();
    info.add(NAME_FIELD, getUnderlying().getName());
    info.add(MODIFICATION_COUNT_FIELD, getUnderlying().getModificationCount());
    final MutableFudgeMsg rules = info.addSubMessage(RULES_FIELD, null);
    for (FunctionBlacklistRule rule : getUnderlying().getRules()) {
      fsc.addToMessage(rules, null, null, rule);
    }
    info.add(JMS_TOPIC_FIELD, _jmsTopic);
    return responseOk(info);
  }
View Full Code Here

Examples of org.fudgemsg.mapping.FudgeSerializer.addToMessage()

110
111
112
113
114
115
116
117
118
119
120
    final int modificationCount = getUnderlying().getModificationCount();
    if (modificationCount != mod) {
      info.add(MODIFICATION_COUNT_FIELD, modificationCount);
      final MutableFudgeMsg rules = info.addSubMessage(RULES_FIELD, null);
      for (FunctionBlacklistRule rule : getUnderlying().getRules()) {
        fsc.addToMessage(rules, null, null, rule);
      }
    }
    return responseOk(info);
  }
View Full Code Here

Examples of org.fudgemsg.mapping.FudgeSerializer.addToMessage()

141
142
143
144
145
146
147
148
149
150
151
  public void ruleAdded(final int modificationCount, final FunctionBlacklistRule rule, final ExecutorService defer) {
    final FudgeSerializer fsc = new FudgeSerializer(getFudgeContext());
    final MutableFudgeMsg msg = fsc.newMessage();
    msg.add(MODIFICATION_COUNT_FIELD, modificationCount);
    final MutableFudgeMsg rulesMessage = msg.addSubMessage(RULES_ADDED_FIELD, null);
    fsc.addToMessage(rulesMessage, null, null, rule);
    defer.submit(new Publish(msg));
  }

  @Override
  public void rulesAdded(final int modificationCount, final Collection<FunctionBlacklistRule> rules, final ExecutorService defer) {
View Full Code Here

Examples of org.fudgemsg.mapping.FudgeSerializer.addToMessage()

152
153
154
155
156
157
158
159
160
161
162
    final FudgeSerializer fsc = new FudgeSerializer(getFudgeContext());
    final MutableFudgeMsg msg = fsc.newMessage();
    msg.add(MODIFICATION_COUNT_FIELD, modificationCount);
    final MutableFudgeMsg rulesMessage = msg.addSubMessage(RULES_ADDED_FIELD, null);
    for (FunctionBlacklistRule rule : rules) {
      fsc.addToMessage(rulesMessage, null, null, rule);
    }
    defer.submit(new Publish(msg));
  }

  @Override
View Full Code Here

Examples of org.fudgemsg.mapping.FudgeSerializer.addToMessage()

163
164
165
166
167
168
169
170
171
172
173
  public void ruleRemoved(final int modificationCount, final FunctionBlacklistRule rule, final ExecutorService defer) {
    final FudgeSerializer fsc = new FudgeSerializer(getFudgeContext());
    final MutableFudgeMsg msg = fsc.newMessage();
    msg.add(MODIFICATION_COUNT_FIELD, modificationCount);
    final MutableFudgeMsg rulesMessage = msg.addSubMessage(RULES_REMOVED_FIELD, null);
    fsc.addToMessage(rulesMessage, null, null, rule);
    defer.submit(new Publish(msg));
  }

  @Override
  public void rulesRemoved(final int modificationCount, final Collection<FunctionBlacklistRule> rules, final ExecutorService defer) {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.