diff --git a/lerna.json b/lerna.json
index 24995ca7e7..37ebbf5c6c 100644
--- a/lerna.json
+++ b/lerna.json
@@ -4,5 +4,5 @@
     "packages/*"
   ],
   "registry": "https://registry.npmjs.org/",
-  "version": "1.0.1-beta.0"
+  "version": "1.0.1-beta.2"
 }
diff --git a/packages/medusa/package.json b/packages/medusa/package.json
index 274bfc8892..1ce1bb60cc 100644
--- a/packages/medusa/package.json
+++ b/packages/medusa/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@medusajs/medusa",
-  "version": "1.0.1-beta.0",
+  "version": "1.0.1-beta.2",
   "description": "E-commerce for JAMstack",
   "main": "dist/app.js",
   "repository": {
diff --git a/packages/medusa/src/models/schemas/fulfillment.js b/packages/medusa/src/models/schemas/fulfillment.js
index 76a4a9368a..a1debd40a2 100644
--- a/packages/medusa/src/models/schemas/fulfillment.js
+++ b/packages/medusa/src/models/schemas/fulfillment.js
@@ -6,5 +6,6 @@ export default new mongoose.Schema({
   items: { type: [mongoose.Schema.Types.Mixed], required: true },
   data: { type: [mongoose.Schema.Types.Mixed], default: {} },
   tracking_numbers: { type: [String], default: [] },
+  shipped_at: { type: String },
   metadata: { type: mongoose.Schema.Types.Mixed, default: {} },
 })
diff --git a/packages/medusa/src/services/order.js b/packages/medusa/src/services/order.js
index 9e92601ef3..1f1430710d 100644
--- a/packages/medusa/src/services/order.js
+++ b/packages/medusa/src/services/order.js
@@ -408,6 +408,7 @@ class OrderService extends BaseService {
         shipment = {
           ...f,
           tracking_numbers: trackingNumbers,
+          shipped_at: Date.now(),
           metadata: {
             ...f.metadata,
             ...metadata,
@@ -712,8 +713,12 @@ class OrderService extends BaseService {
         }
       )
       .then(result => {
-        // Notify subscribers
-        this.eventBus_.emit(OrderService.Events.UPDATED, result)
+        for (const fulfillment of results) {
+          this.eventBus_.emit(OrderService.Events.FULFILLMENT_CREATED, {
+            order_id: orderId,
+            fulfillment,
+          })
+        }
         return result
       })
       .catch(err => {