Thanks Greg, on the root of the stream that works.
I am using a poler based on the getting started code to go through the syndication items (starting from last known position): http://pastebin.com/ceaK0xGp
It dispatches the events:
Dispatching event http://127.0.0.1:2113/streams/customer-71464221/0
Dispatching event http://127.0.0.1:2113/streams/customer-71464221/1
Dispatching event http://127.0.0.1:2113/streams/customer-67981065/0
Dispatching event http://127.0.0.1:2113/streams/customer-67981065/1
Dispatching event http://127.0.0.1:2113/streams/customer-12307621/0
Dispatching event http://127.0.0.1:2113/streams/customer-12307621/1
Dispatching event http://127.0.0.1:2113/streams/customer-72879842/0
Dispatching event http://127.0.0.1:2113/streams/customer-72879842/1
Dispatching event http://127.0.0.1:2113/streams/customer-69396686/0
Dispatching event http://127.0.0.1:2113/streams/customer-69396686/1
Dispatching event http://127.0.0.1:2113/streams/customer-65913530/0
Dispatching event http://127.0.0.1:2113/streams/customer-65913530/1
It would be great if there was a specific metadata query that I could call for the specific single event: http://127.0.0.1:2113/streams/customer-65913530/1?metadata.
If I call http://127.0.0.1:2113/streams/customer-20516703?embed=content the reply could be very long if lots entries in the stream.
Is getting metadata for one event not made easy with the system architecture (which everything being immutable is amazing btw)?
Just trying to avoid writing more code for the sync class
C:\Users\csmorley\Downloads>curl -v -i “http://127.0.0.1:2113/streams/customer-20516703?embed=content” -u admin:changeit
-H “Accept: application/json”
GET /streams/customer-20516703?embed=content HTTP/1.1
Host: 127.0.0.1:2113
Authorization: Basic YWRtaW46Y2hhbmdlaXQ=
User-Agent: curl/7.43.0
Accept: application/json
< HTTP/1.1 200 OK
HTTP/1.1 200 OK
< Cache-Control: max-age=0, no-cache, must-revalidate
Cache-Control: max-age=0, no-cache, must-revalidate
< Content-Length: 3590
Content-Length: 3590
< Content-Type: application/json; charset=utf-8
Content-Type: application/json; charset=utf-8
< ETag: “1;1391431453”
ETag: “1;1391431453”
< Vary: Accept
Vary: Accept
< Server: Microsoft-HTTPAPI/2.0
Server: Microsoft-HTTPAPI/2.0
< Access-Control-Allow-Methods: POST, DELETE, GET, OPTIONS
Access-Control-Allow-Methods: POST, DELETE, GET, OPTIONS
< Access-Control-Allow-Headers: Content-Type, X-Requested-With, X-PINGOTHER, Authorization, ES-LongPoll, ES-ExpectedVers
ion, ES-EventId, ES-EventType, ES-RequiresMaster, ES-HardDelete, ES-ResolveLinkTo, ES-ExpectedVersion
Access-Control-Allow-Headers: Content-Type, X-Requested-With, X-PINGOTHER, Authorization, ES-LongPoll, ES-ExpectedVersio
n, ES-EventId, ES-EventType, ES-RequiresMaster, ES-HardDelete, ES-ResolveLinkTo, ES-ExpectedVersion
< Access-Control-Allow-Origin: *
Access-Control-Allow-Origin: *
< Access-Control-Expose-Headers: Location, ES-Position
Access-Control-Expose-Headers: Location, ES-Position
< Date: Mon, 13 Jul 2015 17:04:35 GMT
<
{
“title”: “Event stream ‘customer-20516703’”,
“id”: “http://127.0.0.1:2113/streams/customer-20516703”,
“updated”: “2015-07-13T17:03:40.7486008Z”,
“streamId”: “customer-20516703”,
“author”: {
“name”: “EventStore”
},
“headOfStream”: true,
“selfUrl”: “http://127.0.0.1:2113/streams/customer-20516703”,
“eTag”: “1;-2060438500”,
“links”: [
{
“uri”: “http://127.0.0.1:2113/streams/customer-20516703”,
“relation”: “self”
},
{
“uri”: “http://127.0.0.1:2113/streams/customer-20516703/head/backward/20”,
“relation”: “first”
},
{
“uri”: “http://127.0.0.1:2113/streams/customer-20516703/2/forward/20”,
“relation”: “previous”
},
{
“uri”: “http://127.0.0.1:2113/streams/customer-20516703/metadata”,
“relation”: “metadata”
}
],
“entries”: [
{
“title”: “1@customer-20516703”,
“id”: “http://127.0.0.1:2113/streams/customer-20516703/1”,
“updated”: “2015-07-13T17:03:40.7486008Z”,
“author”: {
“name”: “EventStore”
},
“summary”: “CustomerChanedAddress”,
“content”: {
“eventStreamId”: “customer-20516703”,
“eventNumber”: 1,
“eventType”: “CustomerChanedAddress”,
“data”: {
“NewAddress”: “new street 123”,
“OccurredOn”: “2015-07-13T17:03:40.7446016Z”,
“EventCorrelationId”: “54d9e71f-25f5-4303-a503-fbe78ea5cf45”
},
“metadata”: {
“CommitId”: “85d0d365-5a4b-465e-9755-aabdc8f65dd1”,
“AggregateClrTypeName”: "ProjectMaster.Domain.Model.Customer.Customer, ProjectMaster, Version=1.0.0.0, Culture
=neutral, PublicKeyToken=null",
“EventClrTypeName”: "ProjectMaster.Domain.Model.Customer.CustomerChanedAddress, ProjectMaster, Version=1.0.0.0
, Culture=neutral, PublicKeyToken=null"
}
},
“links”: [
{
“uri”: “http://127.0.0.1:2113/streams/customer-20516703/1”,
“relation”: “edit”
},
{
“uri”: “http://127.0.0.1:2113/streams/customer-20516703/1”,
“relation”: “alternate”
}
]
},
{
“title”: “0@customer-20516703”,
“id”: “http://127.0.0.1:2113/streams/customer-20516703/0”,
“updated”: “2015-07-13T17:03:40.7486008Z”,
“author”: {
“name”: “EventStore”
},
“summary”: “CustomerCreated”,
“content”: {
“eventStreamId”: “customer-20516703”,
“eventNumber”: 0,
“eventType”: “CustomerCreated”,
“data”: {
“Name”: “chris”,
“Address”: “abc street”,
“PersonId”: {
“SocialSecurityNumber”: 20516703
},
“OccurredOn”: “2015-07-13T17:03:40.7446016Z”,
“EventCorrelationId”: “9282e129-7c33-45cd-afba-b4a115f079f9”
},
“metadata”: {
“CommitId”: “85d0d365-5a4b-465e-9755-aabdc8f65dd1”,
“AggregateClrTypeName”: "ProjectMaster.Domain.Model.Customer.Customer, ProjectMaster, Version=1.0.0.0, Culture
=neutral, PublicKeyToken=null",
“EventClrTypeName”: "ProjectMaster.Domain.Model.Customer.CustomerCreated, ProjectMaster, Version=1.0.0.0, Cult
ure=neutral, PublicKeyToken=null"
}
},
“links”: [
{
“uri”: “http://127.0.0.1:2113/streams/customer-20516703/0”,
“relation”: “edit”
},
{
“uri”: “http://127.0.0.1:2113/streams/customer-20516703/0”,
“relation”: “alternate”
}
]
}
]
}* Connection #0 to host 127.0.0.1 left intact