Keep topic and envelope construction private

[onehouse] / protocol / batch_payload.go

diff --git a/protocol/batch_payload.go b/protocol/batch_payload.go
index 36709398ca6ffdfd6c41ae1b21eed9f37a10ddd5..6e0f07be3ba73c8cf3541a983db0a87dce49d3fb 100644 (file)
--- a/protocol/batch_payload.go
+++ b/protocol/batch_payload.go
@@ -21,13 +21,10 @@ func (b BatchPayload) MarshalJSON() ([]byte, error) {
 
        for _, command := range b.Commands {
                commands = append(commands, batchWireCommand{
 
        for _, command := range b.Commands {
                commands = append(commands, batchWireCommand{

-                       Schema: Schema,
-
-                       Metadata: command.Metadata,
-
+                       Schema:     Schema,
+                       Metadata:   command.Metadata,

                        Capability: command.Capability,
                        Capability: command.Capability,

-
-                       Payload: command.Payload,
+                       Payload:    command.Payload,

                })
        }
 
                })
        }
 


@@ -56,11 +53,9 @@ func (b *BatchPayload) UnmarshalJSON(data []byte) error {
                }
 
                commands = append(commands, BatchCommand{
                }
 
                commands = append(commands, BatchCommand{

-                       Metadata: command.Metadata,
-
+                       Metadata:   command.Metadata,

                        Capability: command.Capability,
                        Capability: command.Capability,

-
-                       Payload: command.Payload,
+                       Payload:    command.Payload,

                })
        }
 
                })
        }