@@ -149,13 +149,13 @@ public String generateMsg(String msgType, JsonObject bodyJson){
149
149
//if input JSON EventType is missing adding query parameter as Type.
150
150
String inputEventType = getInputEventType (bodyJson );
151
151
if (inputEventType == null || inputEventType .isEmpty ()){
152
- bodyJson .get (MSG_PARAMS ).getAsJsonObject ().get (META ).getAsJsonObject ().addProperty (TYPE , msgType );
153
- }else if (!(inputEventType .equals (msgType ))){
152
+ bodyJson .get (MSG_PARAMS ).getAsJsonObject ().get (META ).getAsJsonObject ().addProperty (TYPE , eiffelType . getEventName () );
153
+ }else if (!(inputEventType .equals (eiffelType . getEventName () ))){
154
154
log .error ("check the input json message type : " + inputEventType );
155
- return createErrorResponse (msgType , supportedEventTypes );
155
+ return createErrorResponse (eiffelType . getEventName (), "Mismatch of eventype in request query parameter with property 'type' in the input json message" );
156
156
}
157
157
158
- Event event = eventCreation (msgType , eventType , msgNodes , eventNodes );
158
+ Event event = eventCreation (eventType , msgNodes , eventNodes );
159
159
160
160
String result = gson .toJson (event );
161
161
try {
@@ -166,9 +166,9 @@ public String generateMsg(String msgType, JsonObject bodyJson){
166
166
}
167
167
return result ;
168
168
}
169
- private static Event eventCreation (String msgType , Class <? extends Event > eventType , JsonObject msgNodes ,
169
+ private static Event eventCreation (Class <? extends Event > eventType , JsonObject msgNodes ,
170
170
JsonObject eventNodes ) {
171
- eventNodes .add ("meta" , msgNodes .get ("meta" ));
171
+ eventNodes .add ("meta" , msgNodes .get ("meta" ));
172
172
Event event = createEvent (eventNodes , eventType );
173
173
event .setMeta (event .generateMeta (event .getMeta ()));
174
174
return event ;
0 commit comments