Update hook amqp

1.3.0/hook/dhcp/src/amqppublisher.cc

@@ -1,4 +1,4 @@
-#include "AMQPcpp.h"
+#include <AMQPcpp.h>
 #include "amqppublisher.h"
 
 #include <string>
@@ -13,15 +13,16 @@ int AMQPPublisher::publish(std::string message)
         ex->Declare("kea", "fanout");
     
         AMQPQueue * qu2 = amqp.createQueue("kea");
-    
+        
         qu2->Declare();
-        qu2->Bind( "kea", "");		
-    
-        ex->setHeader("Delivery-mode", 2);
+        qu2->Bind("kea", "");
+        
+        ex->setHeader("Expiration", "10000");
+        ex->setHeader("Delivery-mode", "2");
         ex->setHeader("Content-type", "text/text");
         ex->setHeader("Content-encoding", "UTF-8");
     
-        ex->Publish(  message , "");				
+        ex->Publish(message, "");				
     } catch (AMQPException e) {
         std::cout << e.getMessage() << std::endl;
     }

1.4.0/hook/dhcp/src/amqppublisher.cc

@@ -1,4 +1,4 @@
-#include "AMQPcpp.h"
+#include <AMQPcpp.h>
 #include "amqppublisher.h"
 
 #include <string>
@@ -13,15 +13,16 @@ int AMQPPublisher::publish(std::string message)
         ex->Declare("kea", "fanout");
     
         AMQPQueue * qu2 = amqp.createQueue("kea");
-    
+        
         qu2->Declare();
-        qu2->Bind( "kea", "");		
-    
-        ex->setHeader("Delivery-mode", 2);
+        qu2->Bind("kea", "");
+        
+        ex->setHeader("Expiration", "10000");
+        ex->setHeader("Delivery-mode", "2");
         ex->setHeader("Content-type", "text/text");
         ex->setHeader("Content-encoding", "UTF-8");
     
-        ex->Publish(  message , "");				
+        ex->Publish(message, "");				
     } catch (AMQPException e) {
         std::cout << e.getMessage() << std::endl;
     }